分享一下DTCP-IP中用到的mutex和condition用法。

Mutex一般有兩種使用情況，一種是單獨使用，保護臨界區。

一種是和condition配合使用，可以等待某condition拿到之後再向下走。

Condition 有兩種signal形式， single和  broadcast,下面例子是signal的，

做個參考。

pthread_cond_t ake_cond  = PTHREAD_COND_INITIALIZER;

pthread_mutex_t ake_mutex = PTHREAD_MUTEX_INITIALIZER;

thread 1: 等待AKE完成的signal

pthread_mutex_lock(&ake_mutex);

if (DTCP_AKE_STATE_GOT_EXCHANGE_KEY !=DTCP_AKE_Get_Current_State()) {

                              pthread_cond_wait(&ake_cond, &ake_mutex);

 //進入wait狀態之後， ake_mutex會處於unlock狀態；

                               //等待拿到ake_cond後，，  ake_mutex會變為lock狀態；

pthread_cond_wait

可以等待condition某段時間之後如果還拿不到則向下執行，我上次使用有些問題，有興趣用到時候可以研究下。

}

pthread_mutex_unlock(&ake_mutex);

thread 2:  AKE完成之後傳送signal

void DTCP_Decrypt_AKE_Finish_Callback(void){

                               DTCPLOGV(DECRYPTTAG, "[%s: %d] enter", __FUNCTION__, __LINE__);

                               pthread_mutex_lock(&ake_mutex);

                               pthread_cond_signal(&ake_cond);

                               pthread_mutex_unlock(&ake_mutex);               

}

/************************************************/

pthread_cond_timedwait 用法

          pthread_mutex_lock(&mutex);

        clock_gettime(CLOCK_MONOTONIC, &tv);
        outtime.tv_sec = tv.tv_sec;
        outtime.tv_nsec = tv.tv_nsec + 100 * 1000 * 1000;

        if(outtime.tv_nsec > 1000 * 1000 * 1000){
            outtime.tv_sec = outtime.tv_sec + outtime.tv_nsec / (1000 * 1000 * 1000);
            outtime.tv_nsec = outtime.tv_nsec % (1000*1000*1000);
        }

        int result = pthread_cond_timedwait(&(pMPthread->m_cond), &mutex, &outtime);
        if (result == ETIMEDOUT) {
            //MGR_LOGT << "pthread_cond_timedwait timeout!!!";
        }
 
        pthread_mutex_unlock(&mutex);

    pthread_condattr_init(&m_attr);
    pthread_condattr_setclock(&m_attr, CLOCK_MONOTONIC);
    pthread_cond_init(&m_cond, &m_attr);

Clock_realtime

更多資料參考：