posix信号量与互斥锁

1、简介

  POSIX信号量是一个sem_t 类型的变量,但POSIX 有两种信号量的实现机制:无名信号量和命名信号量。无名信号量可以用在共享内存的情况下,

  比如实现进程中各个线程之间的互斥和同步。命名信号量通常用于不共享内存的情况下,比如不共享内存的进程之间。

1.1POSIX 无名信号量

  在使用信号量之前,必须对其进行初始化。sem_init 函数初始化指定的信号量:

  int sem_init (sem_t *sem, int pshared, unsigned int value)

  无名信号量(也称为基于内存的信号量)sem初始化,设置共享选项pshared,并指定一个整数类型的初始值为value。pshared参数控制着信号量的类型。

  如果 pshared的值是0,就表示它是当前里程的局部信号量;否则,其它进程就能够共享这个信号量。

  intsem_destroy(sem_t *sem);

  释放无名信号量。

1.2POSIX 命名信号量

  之所以称为命名信号量,是因为它有一个名字、一个用户ID、一个组ID和权限,这些是提供给不共享内存的那些进程使用命名信号量的接口。命名信号量的名字是一个遵守路径名构造规则的字符串。

  sem_t*sem_open(const char *name,int oflag,mode_t mode,unsigned int value);

  参数 name 是一个标识信号量的字符串。参数oflag 用来确定是创建信号量还是连接已有信号量。如果设置了oflag 的O_CREAT 比特位,则会创建一个新的信号量。

  有名信号量(返回值)的创建和初始化。出错时返回为SEM_FAILED。

  int sem_close(sem_t *sem);

  单个程序可以用sem_close函数关闭命名信号量,但是这样做并不能将信号量从系统中删除,因为命名信号量在单个程序的执行之外是具有持久性的。

  当进程调用_exit、exit、exec 或从main 返回时,进程打开的命名信号量同样会被关闭。对应有名信号量的关闭,注意不是销毁,是关闭。

  int sem_unlink(count char*name);

  sem_unlink函数用于在所有进程关闭了命名信号量之后,将信号量从系统中删除。对应有名信号量的销毁,每个信号都有一个引用计数器记录当前的打开次数,

  sem_unlink必须等待这个数为0时才能把name所指的信号灯从文件系统中删除。也就是要等待最后一个sem_close发生

1.3信号量的操作函数为sem_post、sem_wait、sem_trywait:

  int sem_wait(sem_t *sem);

  int sem_trywait(sem_t *sem);

  对应信号量的P操作。 sem_wait和sem_trywait的差别是:当所指定信号灯的值已是0时,后者并不将调用线程投入睡眠。相反,他返回一个EAGAIN错误。

  int sem_post(sem_t *sem);

  int sem_getvalue(sem_t *sem,int *valp);

  对应信号量的V操作。

2、互斥锁是通过锁的机制来实现线程间的同步问题。互斥锁的基本流程为:

  初始化一个互斥锁:pthread_mutex_init()函数

  加锁:pthread_mutex_lock()函数或者pthread_mutex_trylock()函数

  对共享资源的操作

  解锁:pthread_mutex_unlock()函数

  注销互斥锁:pthread_mutex_destory()函数

  其中,在加锁过程中,pthread_mutex_lock()函数和pthread_mutex_trylock()函数的过程略有不同:

    当使用pthread_mutex_lock()函数进行加锁时,若此时已经被锁,则尝试加锁的线程会被阻塞,直到互斥锁被其他线程释放,当pthread_mutex_lock()函数有返回值时,说明加锁成功;

    而使用pthread_mutex_trylock()函数进行加锁时,若此时已经被锁,则会返回EBUSY的错误码。

  同时,解锁的过程中,也需要满足两个条件:

    解锁前,互斥锁必须处于锁定状态;

    必须由加锁的线程进行解锁。

  当互斥锁使用完成后,必须进行清除。

  初始化互斥锁

  int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *attr);

  功能:初始化一个互斥锁。

  参数:mutex:互斥锁地址。类型是 pthread_mutex_t 。
       attr:设置互斥量的属性,通常可采用默认属性,即可将 attr 设为 NULL。

  可以使用宏 PTHREAD_MUTEX_INITIALIZER 静态初始化互斥锁,比如:

     pthread_mutex_t  mutex = PTHREAD_MUTEX_INITIALIZER;

  这种方法等价于使用 NULL 指定的 attr 参数调用 pthread_mutex_init() 来完成动态初始化,不同之处在于 PTHREAD_MUTEX_INITIALIZER 宏不进行错误检查。

  返回值:成功:0,成功申请的锁默认是打开的。失败:非 0 错误码

  上锁

  int pthread_mutex_lock(pthread_mutex_t *mutex); 

  功能:对互斥锁上锁,若互斥锁已经上锁,则调用者一直阻塞,直到互斥锁解锁后再上锁。

  参数:mutex:互斥锁地址。

  返回值:成功:0,失败:非 0 错误码

  int pthread_mutex_trylock(pthread_mutex_t *mutex);

  调用该函数时,若互斥锁未加锁,则上锁,返回 0;若互斥锁已加锁,则函数直接返回失败,即 EBUSY。

  解锁

  int pthread_mutex_unlock(pthread_mutex_t * mutex);

  功能:对指定的互斥锁解锁。

  参数:mutex:互斥锁地址。

  返回值:成功:0,失败:非 0 错误码

  销毁互斥锁

  int pthread_mutex_destroy(pthread_mutex_t *mutex);

  功能:销毁指定的一个互斥锁。互斥锁在使用完毕后,必须要对互斥锁进行销毁,以释放资源。

  参数:mutex:互斥锁地址。

  返回值:成功:0,失败:非 0 错误码

#include <unistd.h>
#include <sys/types.h>
#include <pthread.h>
#include <semaphore.h> #include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h> #define ERR_EXIT(m) \
do \
{ \
perror(m); \
exit(EXIT_FAILURE); \
} while() #define CONSUMERS_COUNT 1
#define PRODUCERS_COUNT 1
#define BUFFSIZE 10 int g_buffer[BUFFSIZE]; unsigned short in = ;
unsigned short out = ;
unsigned short produce_id = ;
unsigned short consume_id = ; sem_t g_sem_full;
sem_t g_sem_empty;
pthread_mutex_t g_mutex; pthread_t g_thread[CONSUMERS_COUNT+PRODUCERS_COUNT]; void* consume(void *arg)
{
int num = (int)arg;
int i;
while ()
{
printf("%d wait buffer not empty\n", num);
sem_wait(&g_sem_empty);
pthread_mutex_lock(&g_mutex);
//消费产品
for (i=; i<BUFFSIZE; i++)
{
printf("%02d ", i);
if (g_buffer[i] == -)
printf("%s", "null");
else
printf("%d", g_buffer[i]); if (i == out)
printf("\t<--consume"); printf("\n");
} consume_id = g_buffer[out];
printf("%d begin consume product %d\n", num, consume_id);
g_buffer[out] = -;
out = (out + ) % BUFFSIZE;
printf("%d end consume product %d\n", num, consume_id); pthread_mutex_unlock(&g_mutex);
sem_post(&g_sem_full); sleep();
}
return NULL;
} void* produce(void *arg)
{
int num = (int)arg;
int i;
while ()
{
printf("%d wait buffer not full\n", num);
sem_wait(&g_sem_full);
pthread_mutex_lock(&g_mutex);
//生产产品的代码
for (i=; i<BUFFSIZE; i++)
{
printf("%02d ", i);
if (g_buffer[i] == -)
printf("%s", "null");
else
printf("%d", g_buffer[i]); if (i == in)
printf("\t<--produce"); printf("\n");
} printf("%d begin produce product %d\n", num, produce_id);
g_buffer[in] = produce_id;
in = (in + ) % BUFFSIZE;
printf("%d end produce product %d\n", num, produce_id++);
pthread_mutex_unlock(&g_mutex);
sem_post(&g_sem_empty); sleep();
}
return NULL;
} int main(void)
{
int i;
for (i=; i<BUFFSIZE; i++)
g_buffer[i] = -; sem_init(&g_sem_full, , BUFFSIZE);
sem_init(&g_sem_empty, , ); pthread_mutex_init(&g_mutex, NULL); for (i=; i<CONSUMERS_COUNT; i++)
pthread_create(&g_thread[i], NULL, consume, (void*)i); for (i=; i<PRODUCERS_COUNT; i++)
pthread_create(&g_thread[CONSUMERS_COUNT+i], NULL, produce, (void*)i); for (i=; i<CONSUMERS_COUNT+PRODUCERS_COUNT; i++)
pthread_join(g_thread[i], NULL); sem_destroy(&g_sem_full);
sem_destroy(&g_sem_empty);
pthread_mutex_destroy(&g_mutex); return ;
}

参考:http://blog.csdn.net/tennysonsky/article/details/46494077

上一篇:js-基本语法2


下一篇:Tornado模板配置