scxf2.cpp

创建生产者和消费者线程 C语言文件管理操作系统中的是通过目录项来的

利用信号量和VC++程序设计环境实现生产者/消费者问题。


/////////////////////////////////////////////////////////////////////


//! 定义信号量

         HANDLE m_S_Producer;  // Semaphore
         HANDLE m_S_Consumer; // Semaphore
         HANDLE m_E_Queue;    // Event
 

//! 假设仓库最多容纳M个物品，开始仓库为空

         m_S_Producer = CreateSemaphore(NULL, M, M, NULL);  //初始计数为M
         m_S_Consumer = CreateSemaphore(NULL, 0, M, NULL);  //初始计数为0
         m_E_Queue = CreateEvent(NULL, FALSE, TRUE, NULL); //自动类型，初始状态为信号态 
 

//!生产者

         if (WaitForSingleObject(m_S_Producer, WaitTime) == WAIT_OBJECT_0)
         {
                   if (WaitForSingleObject(m_E_Queue, WaitTime) == WAIT_OBJECT_0)
                   {// OK now, put product     

                            // relase comsumer’s semaphore
                            ReleaseSemaphore(m_S_Consumer, 1, NULL);
                            // set event to signal 
                            SetEvent(m_E_Queue);
                            return TRUE;
                   }

                   else // wait event time out

                   {
                            // not put product so release producer
                            ReleaseSemaphore(m_S_Producer, 1, NULL);
                            SetEvent(m_E_Queue);
                            return FALSE;
                   }
         }

         else // wait semaphore time out
         {
                return FALSE;
         }
}

 

//!消费者

         if (WaitForSingleObject(m_S_Consumer, WaitTime) == WAIT_OBJECT_0)

         {
                   if (WaitForSingleObject(m_E_Queue, WaitTime) == WAIT_OBJECT_0)
                   {// OK now, Get product then
                            // releasee productor’s semaphore
                            ReleaseSemaphore(m_S_Producer, 1, NULL);
                            // set event to signal
                            SetEvent(m_E_Queue);
                            return TRUE;
                   }

                   else // wait event time out
                   {// not get product  so release Consumer

                            ReleaseSemaphore(m_S_Consumer, 1, NULL);
                            SetEvent(m_E_Queue);
                            return FALSE;
                   }
         }

         else // wait semaphore time out
         {
                   return FALSE;
         }

}


特别需要注意的是，在该模型中，对互斥量（本例为m_E_Queue）的等待必须放在第二个等待位置，否则可能将造成线程死锁。考虑这样的情况：仓库已满，没有任何线程访问。某一时刻，生产者放入物品，首先等待m_E_Queue并通过，且将m_E_Queue置于无信号态，然后等待m_S_Produce时被阻塞。这时某一消费者欲取物品，无论在什么情况下，都将在等待m_E_Queue时被阻塞，从而相互等待造成死锁。在释放同步对象时则位置不受限制。