利用POSIX互斥锁和条件变量实现的信号量
2011-09-20 10:10
369 查看
这是一篇从http://man.yolinux.com/cgi-bin/man2html?cgi_command=pthread_mutexattr_init转载过来的文章。
利用POSIX互斥锁、条件变量,和内存映射文件,实现的信号量机制,用于进程间的同步。
利用POSIX互斥锁、条件变量,和内存映射文件,实现的信号量机制,用于进程间的同步。
/* sem.h */ struct semaphore { pthread_mutex_t lock; pthread_cond_t nonzero; unsigned count; }; typedef struct semaphore semaphore_t; semaphore_t* semaphore_create(char *semaphore_name); semaphore_t* semaphore_open(char *semaphore_name); void semaphore_post(semaphore_t *semap); void semaphore_wait(semaphore_t *semap); void semaphore_close(semaphore_t *semap); /* sem.c */ #include <sys/types.h> #include <sys/stat.h> #include <sys/mman.h> #include <fcntl.h> #include <pthread.h> #include "sem.h" semaphore_t* semaphore_create(char *semaphore_name) { int fd = open(semaphore_name, O_RDWR | O_CREAT | O_EXCL, 0666); if (fd < 0) return (NULL); (void) ftruncate(fd, sizeof(semaphore_t)); pthread_mutexattr_t psharedm; pthread_condattr_t psharedc; (void) pthread_mutexattr_init(&psharedm); (void) pthread_mutexattr_setpshared(&psharedm, PTHREAD_PROCESS_SHARED); (void) pthread_condattr_init(&psharedc); (void) pthread_condattr_setpshared(&psharedc, PTHREAD_PROCESS_SHARED); semaphore_t* semap = (semaphore_t *) mmap(NULL, sizeof(semaphore_t), PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); close (fd); (void) pthread_mutex_init(&semap->lock, &psharedm); (void) pthread_cond_init(&semap->nonzero, &psharedc); // 我觉得应该给个大于零的初值 semap->count = 0; return (semap); } semaphore_t* semaphore_open(char *semaphore_name) { int fd = open(semaphore_name, O_RDWR, 0666); if (fd < 0) return (NULL); semaphore_t* semap = (semaphore_t *) mmap(NULL, sizeof(semaphore_t), PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); close (fd); return (semap); } void semaphore_post(semaphore_t *semap) { pthread_mutex_lock(&semap->lock); // 计数为零,说明可能有线程已经阻塞在该条件变量上 if (semap->count == 0) { pthread_cond_signal(&semapx->nonzero); } semap->count++; pthread_mutex_unlock(&semap->lock); } void semaphore_wait(semaphore_t *semap) { pthread_mutex_lock(&semap->lock); // 计数为零,说明已无资源,等待 while (semap->count == 0) { pthread_cond_wait(&semap->nonzero, &semap->lock); } semap->count--; pthread_mutex_unlock(&semap->lock); } void semaphore_close(semaphore_t *semap) { munmap((void *) semap, sizeof(semaphore_t)); }
相关文章推荐
- 利用POSIX互斥锁和条件变量实现的信号量
- 利用POSIX互斥锁和条件变量实现的信号量
- 进程间通信机制(管道、信号、共享内存/信号量/消息队列)、线程间通信机制(互斥锁、条件变量、posix匿名信号量)
- 进程间通信机制(管道、信号、共享内存/信号量/消息队列)、线程间通信机制(互斥锁、条件变量、posix匿名信号量)
- 进程间通信机制(管道、信号、共享内存/信号量/消息队列)、线程间通信机制(互斥锁、条件变量、posix匿名信号量)
- 进程间通信机制(管道、信号、共享内存/信号量/消息队列)、线程间通信机制(互斥锁、条件变量、posix匿名信号量)
- APUE笔记---线程同步之互斥锁、读写锁、条件变量、POSIX信号量
- 利用互斥信号量实现两个线程打印AB,输出5次
- 读写锁的几种实现方式-互斥量,信号量,条件变量
- 信号量:整型、记录型信号量以及利用信号量实现进程互斥和前驱关系
- Java Note: 多线程的同步(互斥锁)的方法对比,信号量锁,读写锁的实现,生产者-消费者模式的实现
- 实现信号量(四) 条件变量实现信号量
- 操作系统算法:如何利用信号量实现优先级(从读者写者问题引发的联想)
- 信号量 互斥锁 条件变量的区别
- 基于POSIX信号量实现生产者消费模型
- POSIX信号量与互斥锁(生产者,消费者)
- python3.4多线程实现同步的四种方式(锁机制、条件变量、信号量和同步队列)
- 信号量、互斥锁,读写锁和条件变量的区别 http://blog.chinaunix.net/uid-20671208-id-4935154.html
- POSIX 信号量和互斥锁
- 多线程用互斥锁和条件变量实现生产者和消费者-------循环任务队列