Linux操作系统下的多线程编程详细解析

时间:2007-06-07 03:07:58  来源:站长资讯收集整理  作者:佚名


void reader_function ( void );
void writer_function ( void );

char buffer;
int buffer_has_item=0;
pthread_mutex_t mutex;
struct timespec delay;
void main ( void ){
　pthread_t reader;
　/* 定义延迟时间*/
　delay.tv_sec = 2;
　delay.tv_nec = 0;
　/* 用默认属性初始化一个互斥锁对象*/
　pthread_mutex_init (&mutex,NULL);
　pthread_create(&reader, pthread_attr_default, (void *)&reader_function), NULL);
　writer_function( );
}

void writer_function (void){
　while(1){
　　/* 锁定互斥锁*/
　　pthread_mutex_lock (&mutex);
　　if (buffer_has_item==0){
　　　buffer=make_new_item( );
　　　buffer_has_item=1;
　　}
　　/* 打开互斥锁*/
　　pthread_mutex_unlock(&mutex);
　　pthread_delay_np(&delay);
　}
}

void reader_function(void){
　while(1){
　　pthread_mutex_lock(&mutex);
　　if(buffer_has_item==1){
　　　consume_item(buffer);
　　　buffer_has_item=0;
　　}
　　pthread_mutex_unlock(&mutex);
　　pthread_delay_np(&delay);
　}
}

　　这里声明了互斥锁变量mutex，结构pthread_mutex_t为不公开的数据类型，其中包含一个系统分配的属性对象。函数pthread_mutex_init用来生成一个互斥锁。NULL参数表明使用默认属性。如果需要声明特定属性的互斥锁，须调用函数pthread_mutexattr_init。函数pthread_mutexattr_setpshared和函数pthread_mutexattr_settype用来设置互斥锁属性。前一个函数设置属性pshared，它有两个取值，PTHREAD_PROCESS_PRIVATE和PTHREAD_PROCESS_SHARED。前者用来不同进程中的线程同步，后者用于同步本进程的不同线程。在上面的例子中，我们使用的是默认属性PTHREAD_PROCESS_ PRIVATE。后者用来设置互斥锁类型，可选的类型有PTHREAD_MUTEX_NORMAL、PTHREAD_MUTEX_ERRORCHECK、PTHREAD_MUTEX_RECURSIVE和PTHREAD _MUTEX_DEFAULT。它们分别定义了不同的上所、解锁机制，一般情况下，选用最后一个默认属性。

　　pthread_mutex_lock声明开始用互斥锁上锁，此后的代码直至调用pthread_mutex_unlock为止，均被上锁，即同一时间只能被一个线程调用执行。当一个线程执行到pthread_mutex_lock处时，如果该锁此时被另一个线程使用，那此线程被阻塞，即程序将等待到另一个线程释放此互斥锁。在上面的例子中，我们使用了pthread_delay_np函数，让线程睡眠一段时间，就是为了防止一个线程始终占据此函数。

文章评论

共有 位CH网友发表了评论 查看完整内容