熟读而精思，循序而渐进，厚积而薄发。
我们还知道，类的静态成员函数是不需要绑定到特定对象上面的，所以我们就可以将worker声明为静态成员。
1 2 3 4 5 6 7 8 9 10 11 | class Thread { public: static void* worker(void* args) { //~ thread execution. } private: //~ here some data member. }; pthread_t tid; pthread_create(&tid, NULL, &Thread::worker, NULL); |
我们又知道，静态成岩函数是不能’直接’访问类的非静态成员（包括函数），因此，上面代码中worker即使属于class Thread的类域，但却无法访问这个类的成员，这让人十分不爽。哪位大牛说过来着？任何一个复杂的计算机问题，都可以通过中间层来解决。这里也可以建立一个中间层：使用静态成员函数创建线程，给该函数传递某个对象的地址作为参数，在该静态函数中就可以通过所传递对象的使用它的任何成员了。
生产者-消费者问题是经典的同步问题，它描述一组生产者进程(线程)向一组消费者进程(线程)提供消息。它们共享一个有界的缓冲池，生产者向其中投放消息，消费者从中取得消息。生产者-消费者问题是许多具体问题中进程(线程)合作的一个很好的抽象。假定缓冲区中有N个位置，每个位置存放一个消息。当缓冲区未满时，生产者可以投入一个消息，否则该进程(线程)阻塞，直到缓冲区内有空位可放；当缓冲区非空时，消费者可以从中取得一个消息，否则该进程(线程)阻塞，直到缓冲区内有消息可取。
为了模拟这一过程，首先需要设置一个大小为N的缓冲区。修改缓冲区时，需要同步各个进程(线程)以免发生错误(向满的缓冲区投放消息或者从空缓冲区内取出消息)。为此，需要设置两个信号量empty和full用以标识缓冲区中空位数和消息数。另外还需要一个互斥锁mutex以互斥地修改缓冲区。为了便于测试，这里缓冲区的大小设置为5，实际情况下，应该尽量大些，以免生产者和消费者相互等待。
/*
* 此处循环判断的原因如下：假设2个线程在getq阻塞，然后两者都被激活，
* 而其中一个线程运行比较块，快速消耗了2个数据，
* 另一个线程醒来的时候已经没有新数据可以消耗了。
* 另一点，man pthread_cond_wait可以看到，
* 该函数可以被信号中断返回，此时返回EINTR。
* 为避免以上任何一点，都必须醒来后再次判断睡眠条件。
* 更正：pthread_cond_wait是信号安全的系统调用，不会被信号中断。
*/
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | int main() { pthread_mutex_init(&mutex, NULL); //~ 初始化互斥锁mutex pthread_t thread_id; void *exit_status; pthread_create(&thread_id, NULL, thread_function, NULL); //~ 创建新线程 for(int i = 0; i < 10; ++i) { usleep(10000); //~ 延时10ms //~ 访问共享数据 pthread_mutex_lock(&mutex); cout<<share<<endl; pthread_mutex_unlock(&mutex); } pthread_join(thread_id, &exit_status); //~ 等待线程结束 pthread_mutex_destroy(&mutex); //~ 销毁互斥锁 return 0; } |