|
用vc实现生产者消费者问题(1)
很多情况下我们需要多个线程互相协助，来完成同一个任务。但是线程很难从外部进行控制。
利用线程同步技术可以使线程彼此交互，从而避免了外部控制对与时间和资源的浪费。
在实际工作过程中我就遇到了类似的问题，需要对共享的缓冲区进行操作。有插入的线程也有
读取的线程，这使我忽然想到了生产者和消费者。我从MSDN 找到CSdn 使用了各式各样的搜索引擎，
只找到了很有现的关于CSemaphore的资料。
//////////////////////////////////////////////////////////////////////////////////////
// 生产者消费者问题
//////////////////////////////////////////////////////////////////////////////////////
生产者要不断将数据放入共享的缓冲，消费者要不断从缓冲取出数据。消费者必须等生产者
取走数据后才能再放新数据(不覆盖数据)，消费者必须等生产者放入新数据后才能去取(不重复)。 //////////////////////////////////////////////////////////////////////////////////////
// 使用信号量的方法
//////////////////////////////////////////////////////////////////////////////////////
当线程使用指定数量的共享资源时，首先调用信号量的lock方法"我能用资源吗"。当有的空闲
共享资源时(此时计数器值>0)线程继续执行并且减少计数器的数量告诉其他线程"我用了××个资
源"。否则挂起自己直到有足够的可用的资源为止。当使用完资源时线程调用unlock方法告诉其他
线程"我已经不用该资源了"。 //////////////////////////////////////////////////////////////////////////////////////
// 实现
////////////////////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////
1创建一个基于对话框的程序。添加如下成员。
//////////////////////////////////////////////////////////
bool m_bSlow;//缓慢显示线程进行的结果 CProdUCerThread *m_pProducerThread;//生产者线程
CConsumerThread *m_pConsumerThread;//消费者线程 CSemaphore* m_pSemaphoreEmpty;//缓冲空的标志
CSemaphore* m_pSemaphoreFull;//缓冲满的标志 CMutex *m_pMutex;//互斥信号量
添加两编辑框用类向导，相关的添加成员
CString m_sBufCSM;//用来显示消费者取到的数据
CString m_sBuf;//显示生产者插入缓冲的数据
//////////////////////////////////////////////////////////
2创建用户界面线程，生产者和消费者线程。
| 
