首页 > 代码库 > pthread_cond_timedwait

pthread_cond_timedwait

2024-07-21 06:06:52   220人阅读





采用pthread_cond_timedwait函数，条件到了，线程即会被join，可及时唤醒线程。实现的如下：

#include <stdio.h>
#include <sys/time.h>
#include <unistd.h>
#include <pthread.h>
#include <errno.h>
 
static pthread_t thread;
static pthread_cond_t cond;
static pthread_mutex_t mutex;
static int flag = 1;
 
void * thr_fn(void * arg) 
{
  struct timeval now;
  struct timespec outtime;
  pthread_mutex_lock(&mutex);
  while (flag) {
    printf("*****\n");
    gettimeofday(&now, NULL);
    outtime.tv_sec = now.tv_sec + 5;
    outtime.tv_nsec = now.tv_usec * 1000;
    pthread_cond_timedwait(&cond, &mutex, &outtime);
  }
  pthread_mutex_unlock(&mutex);
  printf("cond thread exit\n");
}
 
int main(void) 
{
  pthread_mutex_init(&mutex, NULL);
  pthread_cond_init(&cond, NULL);
  if (0 != pthread_create(&thread, NULL, thr_fn, NULL)) {
    printf("error when create pthread,%d\n", errno);
    return 1;
  }
  char c ;
  while ((c = getchar()) != ‘q‘);
  printf("Now terminate the thread!\n");

  pthread_mutex_lock(&mutex);
  flag = 0;
  pthread_cond_signal(&cond);
  pthread_mutex_unlock(&mutex);
  printf("Wait for thread to exit\n");
  pthread_join(thread, NULL);
  printf("Bye\n");
  return 0;
}

pthread_cond_timedwait()函数阻塞住调用该函数的线程，等待由cond指定的条件被触发（pthread_cond_broadcast() or pthread_cond_signal()）。

　　当pthread_cond_timedwait()被调用时，调用线程必须已经锁住了mutex。函数pthread_cond_timedwait()会对mutex进行【解锁和执行对条件的等待】（原子操作）。




关于socket数据的队列实现：

#include <deque>

#include <sys/types.h>

#include <sys/time.h>

#include <stdio.h>

#include <unistd.h>

#include <pthread.h>

#include <errno.h>

#include <stdio.h>


#include "cocos2d.h"

using namespace std;


template<class DataType>   //接收的数据队列，对队列的数据操作是需要线程互斥的

class Queue

{

public:

    Queue():_nready(0)

    {

        pthread_mutex_init(&_mutex, NULL);

        pthread_cond_init(&_cond, NULL);

    }

    

    ~Queue()

    {

       

        pthread_mutex_lock(&_mutex); 

        _queue.clear();

        pthread_mutex_unlock(&_mutex);

        

        pthread_mutex_destroy(&_mutex);

        pthread_cond_destroy(&_cond);

    }

    

    void put_msg(DataType d)

    {

        pthread_mutex_lock(&_mutex); 

        _queue.push_back(d);

        _nready++;

        pthread_mutex_unlock(&_mutex);

pthread_cond_signal(&_cond);

    }

    void push_msg(DataType d)

    {

        pthread_mutex_lock(&_mutex); 

        _queue.push_back(d);

        _nready++;

        pthread_mutex_unlock(&_mutex);

    }


    void get_msg(DataType &d)

    {

        pthread_mutex_lock(&_mutex); 

        while (_nready == 0)

              pthread_cond_wait(&_cond, &_mutex);

        _nready--;

        d = _queue.front();

        _queue.pop_front();

        pthread_mutex_unlock(&_mutex);

    }

    int pop_msg(DataType &d)

    {

        pthread_mutex_lock(&_mutex); 

        if (_nready == 0)

{

pthread_mutex_unlock(&_mutex);

return -1;

}

        _nready--;

        d = _queue.front();

        _queue.pop_front();

        pthread_mutex_unlock(&_mutex);

return0;

    }

    

    int get_msg(DataType &d, int sec)

    {

        timeval now;

        struct timespec timeout;

        int retval = 0;

        

        pthread_mutex_lock(&_mutex); 

        while (_nready == 0) //在一定时长保持等待数据

        {

            gettimeofday(&now, NULL);

            timeout.tv_sec = now.tv_sec + sec;

            timeout.tv_nsec = now.tv_usec * 1000;

            retval = pthread_cond_timedwait(&_cond, &_mutex, &timeout);

            if (retval == ETIMEDOUT)

            {

                pthread_mutex_unlock(&_mutex);

                return -1;

            }

        }

        _nready--;

        d = _queue.front();

        _queue.pop_front();

        pthread_mutex_unlock(&_mutex);

        return 0;

    }

    

    void reset_msg()

    {

        pthread_mutex_lock(&_mutex); 

        _queue.clear();

        _nready = 0;

        pthread_mutex_unlock(&_mutex);

    }

    

private:

int _type;

    pthread_cond_t      _cond;

    int                 _nready;

    pthread_mutex_t     _mutex;

    deque<DataType>     _queue;

};


#endif    /* _QUEUE_H_ */

pthread_cond_timedwait


联系
我们