首页 > 代码库 > 进程之互斥
进程之互斥
题目
共要卖票20张,由命令行输入窗口数,由线程模拟窗口。每卖掉一张票,屏幕显示由几号窗口所卖,一并显示剩余票数
思路
由于票数 ticket_cnt 是全局变量,因此每当一个线程将其减一(卖出一张票),并将其显示,应该被封装为一个原子操作。因为线程是并发执行的,可能当前线程将ticket_cnt减1后还没有来得及显示此时的剩余票数ticket_cnt,ticket_cnt已经被另一个线程减一了。此处通过互斥锁实现互斥。
函数原型
创建线程:
NAME pthread_create - create a new threadSYNOPSIS #include <pthread.h> int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine) (void *), void *arg); Compile and link with -pthread.
回收线程资源,该函数为阻塞函数。
NAME pthread_join - join with a terminated threadSYNOPSIS #include <pthread.h> int pthread_join(pthread_t thread, void **retval); Compile and link with -pthread.DESCRIPTION The pthread_join() function waits for the thread specified by thread to terminate. If that thread has already termi- nated, then pthread_join() returns immediately. The thread specified by thread must be joinable. If retval is not NULL, then pthread_join() copies the exit status of the target thread (i.e., the value that the tar- get thread supplied to pthread_exit(3)) into the location pointed to by *retval. If the target thread was canceled, then PTHREAD_CANCELED is placed in *retval. If multiple threads simultaneously try to join with the same thread, the results are undefined. If the thread calling pthread_join() is canceled, then the target thread will remain joinable (i.e., it will not be detached).RETURN VALUE On success, pthread_join() returns 0; on error, it returns an error number.
解锁开锁
NAME pthread_mutex_lock pthread_mutex_unlock - lock and unlock a mutexSYNOPSIS #include <pthread.h> int pthread_mutex_lock(pthread_mutex_t *mutex); int pthread_mutex_unlock(pthread_mutex_t *mutex);
初始化锁,销毁锁
NAME pthread_mutex_destroy, pthread_mutex_init - destroy and initialize a mutexSYNOPSIS #include <pthread.h> int pthread_mutex_destroy(pthread_mutex_t *mutex); int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr);
代码
/************************************************************************* > File Name: ticket.c > Author: KrisChou > Mail:zhoujx0219@163.com > Created Time: Mon 25 Aug 2014 07:40:38 PM CST ************************************************************************/#include <stdio.h>#include <stdlib.h>#include <string.h>#include <pthread.h>int ticket_cnt = 20; /* 共有20张票 */typedef struct tag{ int s_id; pthread_mutex_t *s_p;}DATA,*pDATA;void* handler(void *arg ){ int id = ((pDATA)arg)->s_id; pthread_mutex_t *p_mutex = ((pDATA)arg)-> s_p; printf("a window on !: %d \n", id); while(1) { pthread_mutex_lock(p_mutex); if(ticket_cnt == 0) { printf("ticket out! \n"); pthread_mutex_unlock(p_mutex); free((pDATA)arg); return (void*)0; } --ticket_cnt; sleep(rand()%3 + 1); printf("window: %d : a ticket sold. left : %d \n", id,ticket_cnt ); pthread_mutex_unlock(p_mutex); sleep(rand() % 3 + 1); /* 如果不sleep,锁会一直被这个执行完的线程所占据 */ }}int main(int argc, char *argv[]){ srand(getpid()); pthread_mutex_t mutex; pthread_mutex_init(&mutex, NULL); int thd_cnt = atoi(argv[1]); /* 从命令行输入卖票窗口数 */ pthread_t *tds = (pthread_t*)calloc(thd_cnt,sizeof(pthread_t)); int index; for(index = 0; index < thd_cnt; index++ ) { pDATA p = (pDATA)calloc(1,sizeof(DATA)); p->s_id = index; p->s_p = &mutex; pthread_create(tds + index , NULL,handler,(void*)p); } printf("joining...\n"); for(index = 0; index < thd_cnt; index++) { pthread_join(tds[index],NULL); } pthread_mutex_destroy(&mutex); return 0;}
编译运行:
[purple@localhost review]$ gcc ticket.c -lpthread[purple@localhost review]$ ./a.out 5joining...a window on !: 2a window on !: 3a window on !: 4a window on !: 1a window on !: 0window: 2 : a ticket sold. left : 19window: 3 : a ticket sold. left : 18window: 4 : a ticket sold. left : 17window: 1 : a ticket sold. left : 16window: 0 : a ticket sold. left : 15window: 2 : a ticket sold. left : 14window: 3 : a ticket sold. left : 13window: 4 : a ticket sold. left : 12window: 1 : a ticket sold. left : 11window: 0 : a ticket sold. left : 10window: 2 : a ticket sold. left : 9window: 3 : a ticket sold. left : 8window: 4 : a ticket sold. left : 7window: 1 : a ticket sold. left : 6window: 0 : a ticket sold. left : 5window: 2 : a ticket sold. left : 4window: 3 : a ticket sold. left : 3window: 4 : a ticket sold. left : 2window: 1 : a ticket sold. left : 1window: 0 : a ticket sold. left : 0ticket out!ticket out!ticket out!ticket out!ticket out!
进程之互斥
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。