欢迎访问:常州市武进区嘉泽中心小学网站 !今天是:
栏目列表
您现在的位置是:首页>>教师>>计算机技术>>程序设计>>杂项>>文章内容
具有Reset功能的多线程同步队列 - 3
发布时间:2008-11-20   点击:   来源:本站原创   录入者:佚名
 

BOOL CTreadSafeMsgQueue::GetMsg(MsgItem &Msg, int WaitTime)

{

         if (!m_bInitedOK) return FALSE;

 

         // 防止在reset期间导致Semaphore计数不正确

         while (m_bStop)

         {

                  TRACE("Thread %d Sleep\n", GetCurrentThreadId());

                  Sleep(SLEEP_TIME);

         }

 

         // 进入同步操作状态

         m_ReadingThreadNum++;

 

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

         {

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

                   {

                            // OK now, Get message then

                           Msg = m_Queue[m_TailToRead++];

                            if (m_TailToRead >= MAX_QUE_SIZE) m_TailToRead = 0;

                            TRACE("Get message === %d\n", Msg.MsgID);

                           

                            ReleaseSemaphore(m_S_Producer, 1, NULL);

                            SetEvent(m_E_Queue);

 

                            m_ReadingThreadNum--;

                            return TRUE;

                   }

                   else // wait event time out

                   {

                            // not Get message so release Consumer

                            ReleaseSemaphore(m_S_Consumer, 1, NULL);

                            SetEvent(m_E_Queue);

        

                            m_ReadingThreadNum--;

                            return FALSE;

                   }

         }

         else // wait semaphore time out

         {

                  m_ReadingThreadNum--;

                   return FALSE;

         }

}


附件:
    关闭窗口
    打印文档
    账号登录
    保持登录 忘记密码?
    账号与武进教师培训平台同步