Posix多线程编程学习笔记（三）—信号灯（3）

╰半夏微凉° 2022-06-12 12:27 300阅读 0赞

**4.posix有名信号灯应用于多进程**

下面就是应用Posix有名信号灯的一个小程序。用它来限制访问共享代码的进程数目。

<table> 
 <tbody> 
 <tr> 
 <td> #include &lt;semaphore.h&gt; #include &lt;unistd.h&gt; #include &lt;stdio.h&gt; #include &lt;fcntl.h&gt; &nbsp; void print(pid_t); sem_t *sem; /*定义Posix有名信号灯*/ int val; /*定义信号灯当前值*/ &nbsp; int main(int argc,char *argv[]) { int n=0; &nbsp; if(argc!=2) { &nbsp;&nbsp;&nbsp; printf(“please input a file name!/n”); &nbsp;&nbsp;&nbsp; exit(1); } sem=sem_open(argv[1],O_CREAT,0644,2); /*打开一个信号灯, 初值设为2*/ &nbsp; while(n++&lt;5) /*循环创建5个子进程，使它们同步运行*/ { &nbsp;&nbsp;&nbsp; if(fork()==0) &nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sem_wait(sem); /*申请信号灯*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; print(getpid()); /*调用共享代码段*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sleep(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sem_post(sem); /*释放信号灯*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; printf(“I’m finished,my pid is %d/n”,getpid()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return 0; &nbsp;&nbsp;&nbsp; } wait(); /*等待所有子进程结束*/ sem_close(sem); sem_unlink(argv[1]); exit(0); } &nbsp; void print(pid_t pid) { printf(“I get it,my pid is %d/n”,pid); sem_getvalue(sem,&amp;val); printf(“Now the value have %d/n”,val); } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

程序编译后运行会得到如下结果：

\#./8\_2 8\_2.c

I get it,my tid is 1082330304

Now the value have 1

I get it,my tid is 1090718784

Now the value have 0

I finished,my pid is 1082330304

I finished,my pid is 1090718784

I get it,my tid is 1099107264

Now the value have 1

I get it,my tid is 1116841120

Now the value have 0

I finished,my pid is 1099107264

I finished,my pid is 1116841120

I get it,my tid is 1125329600

Now the value have 1

I finished,my pid is 1125329600

**二、基于内存的信号灯**

前面已经介绍了Posix有名信号灯。这些信号灯由一个name参数标识，它通常指代文件系统中的某个文件。然而Posix也提供基于内存的信号灯，它们由应用程序分配信号灯的内存空间，然后由系统初始化它们的值。

<table> 
 <tbody> 
 <tr> 
 <td> 名称:： </td> 
 <td> sem_init/sem_destroy </td> 
 </tr> 
 <tr> 
 <td> 功能： </td> 
 <td> 初始化/关闭信号等 </td> 
 </tr> 
 <tr> 
 <td> 头文件： </td> 
 <td> #include &lt;semaphore.h&gt; </td> 
 </tr> 
 <tr> 
 <td> 函数原形： </td> 
 <td> int sem_init(sem_t *sem,int shared,unsigned int value); int sem_getvalue(sem_t *sem); </td> 
 </tr> 
 <tr> 
 <td> 参数： </td> 
 <td> sem&nbsp;&nbsp;&nbsp; 指向信号灯的指针 shared&nbsp; 作用范围 value&nbsp;&nbsp; 信号灯初始值 </td> 
 </tr> 
 <tr> 
 <td> 返回值： </td> 
 <td> 若成功则返回0，否则返回-1。 </td> 
 </tr> 
 </tbody> 
</table>

基于内存的信号灯是由sem\_init初始化的。sem参数指向必须由应用程序分配的sem\_t变量。如果shared为0，那么待初始化的信号灯是在同一进程的各个线程共享的，否则该信号灯是在进程间共享的。当shared为零时，该信号灯必须存放在即将使用它的所有进程都能访问的某种类型的共享内存中。跟sem\_open一样，value参数是该信号灯的初始值。

使用完一个基于内存的信号灯后，我们调用sem\_destroy关闭它。

除了sem\_open和sem\_close外，其它的poisx有名信号灯函数都可以用于基于内存的信号灯。

注意：posix基于内存的信号灯和posix有名信号灯有一些区别，我们必须注意到这些。

1.sem\_open不需要类型与shared的参数，有名信号灯总是可以在不同进程间共享的。

2.sem\_init不使用任何类似于O\_CREAT标志的东西，也就是说，sem\_init总是初始化信号灯的值。因此，对于一个给定的信号灯，我们必须小心保证只调用一次sem\_init。

3.sem\_open返回一个指向某个sem\_t变量的指针，该变量由函数本身分配并初始化。但sem\_init的第一个参数是一个指向某个sem\_t变量的指针，该变量由调用者分配，然后由sem\_init函数初始化。

4.posix有名信号灯是通过内核持续的，一个进程创建一个信号灯，另外的进程可以通过该信号灯的外部名（创建信号灯使用的文件名）来访问它。posix基于内存的信号灯的持续性却是不定的，如果基于内存的信号灯是由单个进程内的各个线程共享的，那么该信号灯就是随进程持续的，当该进程终止时它也会消失。如果某个基于内存的信号灯是在不同进程间同步的，该信号灯必须存放在共享内存区中，这要只要该共享内存区存在，该信号灯就存在。

5.基于内存的信号灯应用于线程很麻烦（待会你会知道为什么），而有名信号灯却很方便，基于内存的信号灯比较适合应用于一个进程的多个线程。

下面是posix基于内存的信号灯实现一个进程的各个线程间的互次。

<table> 
 <tbody> 
 <tr> 
 <td> #include &lt;semaphore.h&gt; #include &lt;unistd.h&gt; #include &lt;stdio.h&gt; #include &lt;fcntl.h&gt; #include &lt;pthread.h&gt; #incude &lt;stdlib.h&gt; &nbsp; void *thread_function(void *arg); /*线程入口函数*/ void print(void); /*共享资源函数*/ &nbsp; sem_t bin_sem; /*定义信号灯*/ int value; /*定义信号量的灯*/ &nbsp; int main() { int n=0; pthread_t a_thread; &nbsp; if((sem_init(&amp;bin_sem,0,2))!=0) /*初始化信号灯，初始值为2*/ { &nbsp;&nbsp;&nbsp; perror(“sem_init”); &nbsp;&nbsp;&nbsp; exit(1); } while(n++&lt;5) /*循环创建5个线程*/ { &nbsp;&nbsp;&nbsp; if((pthread_create(&amp;a_thread,NULL,thread_function,NULL))!=0) { &nbsp;&nbsp;&nbsp; perror(“Thread creation failed”); &nbsp;&nbsp;&nbsp; exit(1); } } pthread_join(a_thread,NULL);/*等待子线程返回*/ } &nbsp; void *thread_function(void *arg) { sem_wait(&amp;bin_sem); /*等待信号灯*/ print(); sleep(1); sem_post(&amp;bin_sem); /*挂出信号灯*/ printf(“I finished,my pid is %d/n”,pthread_self()); pthread_exit(arg); } &nbsp; void print() { printf(“I get it,my tid is %d/n”,pthread_self()); sem_getvalue(&amp;bin_sem,&amp;value); /*获取信号灯的值*/ printf(“Now the value have %d/n”,value); } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

posix基于内存的信号灯和有名信号灯基本是一样的，上面的几点区别就可以了。

下面是运行结果：

\#gcc –lpthread –o seminitthread seminitthread.c

\#./seminitthread

I get it,my tid is 1082330304

Now the value have 1

I get it,my tid is 1090718784

Now the value have 0

I finished,my pid is 1082330304

I finished,my pid is 1090718784

I get it,my tid is 1099107264

Now the value have 1

I get it,my tid is 1116841120

Now the value have 0

I finished,my pid is 1099107264

I finished,my pid is 1116841120

I get it,my tid is 1125329600

Now the value have 1

I finished,my pid is 1125329600

下面的程序并不能得到我们想要的结果。

<table> 
 <tbody> 
 <tr> 
 <td> #include &lt;semaphore.h&gt; #include &lt;unistd.h&gt; #include &lt;stdio.h&gt; #include &lt;fcntl.h&gt; &nbsp; void print(pid_t); sem_t *sem; /*定义Posix有名信号灯*/ int val; /*定义信号灯当前值*/ &nbsp; int main(int argc,char *argv[]) { int n=0; &nbsp; sem=sem_open(argv[1],O_CREAT,0644,3); /*打开一个信号灯*/ sem_getvalue(sem,&amp;val); /*查看信号灯的值*/ printf(“The value have %d/n”,val); &nbsp; while(n++&lt;5) /*循环创建5个子进程，使它们同步运行*/ { &nbsp;&nbsp;&nbsp; if(fork()==0) &nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sem_wait(sem); /*申请信号灯*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; print(getpid()); /*调用共享代码段*/ &nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sleep(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sem_post(sem); /*释放信号灯*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; printf(“I’m finished,my pid is %d/n”,getpid()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return 0; &nbsp;&nbsp;&nbsp; } wait(); /*等待所有子进程结束*/ return 0; } &nbsp; void print(pid_t pid) { printf(“I get it,my pid is %d/n”,pid); sem_getvalue(sem,&amp;val); printf(“Now the value have %d/n”,val); } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

下面是运行结果：

\#cc –lpthread –o sem sem.c

\#./sem

The value have 3

I get it,my pid is 2236

Now the value have 2

I get it,my pid is 2237

Now the value have 2

I get it,my pid is 2238

Now the value have 2

I get it,my pid is 2239

Now the value have 2