Linux/Unix 多线程通讯

时间 2019-11-09

原文原文链接

线程间无需特别的手段进行通讯，由于线程间能够共享数据结构，也就是一个全局变量能够被两个线程同时使用。不过要注意的是线程间须要作好同步，通常用 mutex。能够参考一些比较新的 UNIX/Linux 编程的书，都会提到 Posix 线程编程，好比《UNIX环境高级编程（第二版）》、《UNIX系统编程》等等。 Linux 的消息属于 IPC，也就是进程间通讯，线程用不上。编程

使用多线程的理由之一是和进程相比，它是一种很是”节俭”的多任务操做方式。缓存

咱们知道，在 Linux 系统下，启动一个新的进程必须分配给它独立的地址空间，创建众多的数据表来维护它的代码段、堆栈段和数据段，这是一种”昂贵”的多任务工做方式。而运行于一个进程中的多个线程，它们彼此之间使用相同的地址空间，共享大部分数据，启动一个线程所花费的空间远远小于启动一个进程所花费的空间，并且，线程间彼此切换所需的时间也远远小于进程间切换所须要的时间。markdown
使用多线程的理由之二是线程间方便的通讯机制。数据结构

对不一样进程来讲，它们具备独立的数据空间，要进行数据的传递只能经过通讯的方式进行，这种方式不只费时，并且很不方便。线程则否则，因为同一进程下的线程之间共享数据空间，因此一个线程的数据能够直接为其它线程所用，这不只快捷，并且方便。固然，数据的共享也带来其余一些问题，有的变量不能同时被两个线程所修改，有的子程序中声明为 static 的数据更有可能给多线程程序带来灾难性的打击，这些正是编写多线程程序时最须要注意的地方。多线程

Table of Contents
通讯方式
- 信号
- 互斥锁
- 条件变量
- 信号量
- 信号量与线程锁、条件变量
简单的多线程程序
- 修改线程的属性
- 线程的数据处理
- 互斥锁
- 信号量

通讯方式

信号

Linux 用 pthread_kill 对线程发信号。函数

Windows 用 PostThreadMessage 进行线程间通讯，但实际上极少用这种方法。仍是利用同步多一些 LINUX 下的同步和 Windows 原理都是同样的。不过 Linux 下的 singal 中断也很好用。post

用好信号量，共享资源就能够了。测试

互斥锁

互斥锁，是一种信号量，经常使用来防止两个进程或线程在同一时刻访问相同的共享资源。优化

须要的头文件：pthread.hspa

互斥锁标识符：pthread_mutex_t

互斥锁初始化：

函数原型： int pthread_mutex_init (pthread_mutex_t* mutex,const pthread_mutexattr_t* mutexattr);

函数传入值: mutex：互斥锁。

mutexattr：
- PTHREAD_MUTEX_INITIALIZER 建立快速互斥锁。
- PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP 建立递归互斥锁。
- PTHREAD_ERRORCHECK_MUTEX_INITIALIZER_NP 建立检错互斥锁。
函数返回值：成功：0；出错：-1
互斥操做函数
- int pthread_mutex_lock(pthread_mutex_t* mutex); //上锁
- int pthread_mutex_trylock (pthread_mutex_t* mutex); //只有在互斥被锁住的状况下才阻塞
- int pthread_mutex_unlock (pthread_mutex_t* mutex); //解锁
- int pthread_mutex_destroy (pthread_mutex_t* mutex); //清除互斥锁
函数传入值：mutex：互斥锁。

函数返回值：成功：0；出错：-1

使用形式：
```
pthread_mutex_t mutex;
pthread_mutex_init (&mutex, NULL); /*定义*/
...
pthread_mutex_lock(&mutex); /*获取互斥锁*/
... /*临界资源*/
pthread_mutex_unlock(&mutex); /*释放互斥锁*/
```
　　
若是一个线程已经给一个互斥量上锁了，后来在操做的过程当中又再次调用了该上锁的操做，那么该线程将会无限阻塞在这个地方，从而致使死锁。这就须要互斥量的属性。

互斥量分为下面三种：
1. 快速型。这种类型也是默认的类型。该线程的行为正如上面所说的。
2. 递归型。若是遇到咱们上面所提到的死锁状况，同一线程循环给互斥量上锁，那么系统将会知道该上锁行为来自同一线程，那么就会赞成线程给该互斥量上锁。
3. 错误检测型。若是该互斥量已经被上锁，那么后续的上锁将会失败而不会阻塞，pthread_mutex_lock()操做将会返回EDEADLK。
互斥量的属性类型为pthread_mutexattr_t。声明后调用pthread_mutexattr_init()来建立该互斥量。而后调用 pthread_mutexattr_settype来设置属性。格式以下：int pthread_mutexattr_settype(pthread_mutexattr_t *attr, int kind);

第一个参数attr，就是前面声明的属性变量；第二个参数kind，就是咱们要设置的属性类型。他有下面几个选项：
- PTHREAD_MUTEX_FAST_NP
- PTHREAD_MUTEX_RECURSIVE_NP
- PTHREAD_MUTEX_ERRORCHECK_NP
下面给出一个使用属性的简单过程：
```
pthread_mutex_t mutex;
pthread_mutexattr_t attr;
pthread_mutexattr_init(&attr);
pthread_mutexattr_settype(&attr,PTHREAD_MUTEX_RECURSIVE_NP);
pthread_mutex_init(&mutex,&attr);
pthread_mutex_destroy(&attr);
```
　　
前面咱们提到在调用pthread_mutex_lock()的时候，若是此时mutex已经被其余线程上锁，那么该操做将会一直阻塞在这个地方。若是咱们此时不想一直阻塞在这个地方，那么能够调用下面函数：pthread_mutex_trylock。

若是此时互斥量没有被上锁，那么pthread_mutex_trylock将会返回0，并会对该互斥量上锁。若是互斥量已经被上锁，那么会马上返回EBUSY。

条件变量

须要的头文件：pthread.h

条件变量标识符：pthread_cond_t

互斥锁的存在问题：

互斥锁一个明显的缺点是它只有两种状态：锁定和非锁定。设想一种简单情景：多个线程访问同一个共享资源时，并不知道什么时候应该使用共享资源，若是在临界区里加入判断语句，或者能够有效，但一来效率不高，二来复杂环境下就难以编写了，这是咱们须要一个结构，能在条件成立时触发相应线程，进行变量修改和访问。
条件变量:

条件变量经过容许线程阻塞和等待另外一个线程发送信号的方法弥补了互斥锁的不足，它常和互斥锁一块儿使用。使用时，条件变量被用来阻塞一个线程，当条件不知足时，线程每每解开相应的互斥锁并等待条件发生变化。一旦其它的某个线程改变了条件变量，它将通知相应的条件变量唤醒一个或多个正被此条件变量阻塞的线程。这些线程将从新锁定互斥锁并从新测试条件是否知足。
条件变量的相关函数
- pthread_cond_t cond = PTHREAD_COND_INITIALIZER; //条件变量结构
- int pthread_cond_init(pthread_cond_t cond, pthread_condattr_tcond_attr);
- int pthread_cond_signal(pthread_cond_t *cond);
- int pthread_cond_broadcast(pthread_cond_t *cond);
- int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex);
- int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex,
- const struct timespec *abstime);
- int pthread_cond_destroy(pthread_cond_t *cond);
详细说明
建立和注销

条件变量和互斥锁同样，都有静态动态两种建立方式
1. 静态方式
  
  静态方式使用PTHREAD_COND_INITIALIZER常量，以下：
  
  pthread_cond_t cond=PTHREAD_COND_INITIALIZER
2. 动态方式
  
  动态方式调用pthread_cond_init()函数，API定义以下：
  
  int pthread_cond_init(pthread_cond_t *cond, pthread_condattr_t *cond_attr)
  
  尽管POSIX标准中为条件变量定义了属性，但在LinuxThreads中没有实现，所以cond_attr值一般为NULL，且被忽略。
  
  注销一个条件变量须要调用pthread_cond_destroy()，只有在没有线程在该条件变量上等待的时候才能注销这个条件变量，不然返回 EBUSY。由于Linux实现的条件变量没有分配什么资源，因此注销动做只包括检查是否有等待线程。API定义以下：int pthread_cond_destroy(pthread_cond_t *cond)
等待和激发
1. 等待
  - int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex) //等待
  - int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex,
  - const struct timespec *abstime) //有时等待
  等待条件有两种方式：无条件等待pthread_cond_wait()和计时等待pthread_cond_timedwait()，其中计时等待方式若是在给定时刻前条件没有知足，则返回ETIMEOUT，结束等待，其中abstime以与time()系统调用相赞成义的绝对时间形式出现，0表示格林尼治时间1970年1月1日0时0分0秒。
  
  不管哪一种等待方式，都必须和一个互斥锁配合，以防止多个线程同时请求pthread_cond_wait()（或 pthread_cond_timedwait()，下同）的竞争条件（Race Condition）。mutex互斥锁必须是普通锁（PTHREAD_MUTEX_TIMED_NP）或者适应锁（PTHREAD_MUTEX_ADAPTIVE_NP），且在调用pthread_cond_wait()前必须由本线程加锁（pthread_mutex_lock()），而在更新条件等待队列之前，mutex保持锁定状态，并在线程挂起进入等待前解锁。在条件知足从而离开 pthread_cond_wait()以前，mutex将被从新加锁，以与进入pthread_cond_wait()前的加锁动做对应。
2. 激发
  
  激发条件有两种形式，pthread_cond_signal()激活一个等待该条件的线程，存在多个等待线程时按入队顺序激活其中一个；而pthread_cond_broadcast()则激活全部等待线程。</p>

其余操做

pthread_cond_wait ()和pthread_cond_timedwait()都被实现为取消点，所以，在该处等待的线程将当即从新运行，在从新锁定mutex后离开 pthread_cond_wait()，而后执行取消动做。也就是说若是pthread_cond_wait()被取消，mutex是保持锁定状态的，于是须要定义退出回调函数来为其解锁。

pthread_cond_wait实际上能够看做是如下几个动做的合体:

解锁线程锁；

等待条件为true；

加锁线程锁；

使用形式：

// 线程一代码
pthread_mutex_lock(&mutex);
if (条件知足)
pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
<p>// 线程二代码
pthread_mutex_lock(&mutex);
while (条件不知足)
pthread_cond_wait(&cond, &mutex);
pthread_mutex_unlock(&mutex);
/*线程二中为何使用while呢？由于在pthread_cond_signal和pthread_cond_wait返回之间，有时间差，假设在这 个时间差内，条件改变了，显然须要从新检查条件。也就是说在pthread_cond_wait被唤醒的时候可能该条件已经不成立。*/

信号量

信号量其实就是一个计数器，也是一个整数。每一次调用 wait 操做将会使 semaphore 值减一，而若是 semaphore 值已经为 0，则 wait 操做将会阻塞。每一次调用post操做将会使semaphore值加一。

须要的头文件：semaphore.h

信号量标识符：sem_t

主要函数：

sem_init

功能：用于建立一个信号量，并初始化信号量的值。

函数原型： int sem_init (sem_t* sem, int pshared, unsigned int value);

函数传入值： sem：信号量。

pshared：决定信号量可否在几个进程间共享。因为目前 Linux 尚未实现进程间共享信息量，因此这个值只能取0。 value：初始计算器

函数返回值： 0：成功；-1：失败。

其余函数

//等待信号量
int sem_wait (sem_t* sem);
int sem_trywait (sem_t* sem);
//发送信号量
int sem_post (sem_t* sem);
//获得信号量值
int sem_getvalue (sem_t* sem);
//删除信号量
int sem_destroy (sem_t* sem);

功能：sem_wait和sem_trywait至关于 P 操做，它们都能将信号量的值减一，二者的区别在于若信号量的值小于零时，sem_wait 将会阻塞进程，而 sem_trywait 则会当即返回。

sem_post 至关于 V 操做，它将信号量的值加一，同时发出唤醒的信号给等待的进程（或线程）。

sem_getvalue 获得信号量的值。

sem_destroy 摧毁信号量。

使用形式：

sem_t sem;
sem_init(&sem, 0, 1); /*信号量初始化*/
...
sem_wait(&sem);   /*等待信号量*/
... /*临界资源*/
sem_post(&sem);   /*释放信号量*/

信号量与线程锁、条件变量

信号量与线程锁、条件变量相比还有如下几点不一样：

锁必须是同一个线程获取以及释放，不然会死锁。而条件变量和信号量则没必要。
信号的递增与减小会被系统自动记住，系统内部有一个计数器实现信号量，没必要担忧会丢失，而唤醒一个条件变量时，若是没有相应的线程在等待该条件变量，此次唤醒将被丢失。

简单的多线程程序

首先在主函数中，咱们使用到了两个函数，pthread_create 和 pthread_join，并声明了一个 pthread_t型的变量。

pthread_t 在头文件 pthread.h 中已经声明，是线程的标示符

函数 pthread_create 用来建立一个线程，函数原型：

#include <pthread.h>

int pthread_create(pthread_t *thread, const pthread_attr_t *attr,
  void *(*start_routine) (void *), void *arg);

第一个参数为指向线程标识符的指针，
第二个参数用来设置线程属性，
第三个参数是线程运行函数的起始地址，
最后一个参数是运行函数的参数。

若咱们的函数thread不须要参数，因此最后一个参数设为空指针。第二个参数咱们也设为空指针，这样将生成默认属性的线程。

返回值:

0: 当建立线程成功时
non-zero: 说明建立线程失败，常见的错误返回代码为
- EAGAIN 表示系统限制建立新的线程，例如线程数目过多了；
- EINVAL 表示第二个参数表明的线程属性值非法。

建立线程成功后，新建立的线程则运行参数三和参数四肯定的函数，原来的线程则继续运行下一行代码。

函数pthread_join用来等待一个线程的结束。函数原型为：

#include <pthread.h>

int pthread_join(pthread_t thread, void **retval);

第一个参数为被等待的线程标识符，第二个参数为一个用户定义的指针，它能够用来存储被等待线程的返回值。这个函数是一个线程阻塞的函数，调用它的函数将一直等待到被等待的线程结束为止，当函数返回时，被等待线程的资源被收回。

一个线程的结束有两种途径，

一种是象咱们上面的例子同样，函数结束了，调用它的线程也就结束了；
另外一种方式是经过函数 pthread_exit 来实现。它的函数原型为：

#include <pthread.h>

void pthread_exit(void *retval);

惟一的参数是函数的返回代码，只要 pthread_join 中的第二个参数 retval 不是NULL，这个值将被传递给 retval。

最后要说明的是，一个线程不能被多个线程等待，不然第一个接收到信号的线程成功返回，其他调用 pthread_join 的线程则返回错误代码 ESRCH。

修改线程的属性

设置线程绑定状态的函数为 pthread_attr_setscope，它有两个参数，第一个是指向属性结构的指针，第二个是绑定类型，它有两个取值：

PTHREAD_SCOPE_SYSTEM（绑定的）
PTHREAD_SCOPE_PROCESS（非绑定的）

下面的代码即建立了一个绑定的线程。

#include <pthread.h>

pthread_attr_t attr;
pthread_t tid;

/*初始化属性值，均设为默认值*/
pthread_attr_init(&attr);
pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM);

pthread_create(&tid, &attr, (void *)task_func, NULL);

线程的数据处理

和进程相比，线程的最大优势之一是数据的共享性，各个进程共享父进程处沿袭的数据段，能够方便的得到、修改数据。

但这也给多线程编程带来了许多问题。咱们必须小心有多个不一样的进程访问相同的变量。许多函数是不可重入的，即同时不能运行一个函数的多个拷贝（除非使用不一样的数据段）。在函数中声明的静态变量经常带来问题，函数的返回值也会有问题。由于若是返回的是函数内部静态声明的空间的地址，则在一个线程调用该函数获得地址后使用该地址指向的数据时，别的线程可能调用此函数并修改了这一段数据。在进程中共享的变量必须用关键字 volatile 来定义，这是为了防止编译器在优化时（如 gcc 中使用 -OX 参数）改变它们的使用方式。为了保护变量，咱们必须使用信号量、互斥等方法来保证咱们对变量的正确使用。

互斥锁

互斥锁用来保证一段时间内只有一个线程在执行一段代码。必要性显而易见：假设各个线程向同一个文件顺序写入数据，最后获得的结果必定是灾难性的

信号量

原来老是用互斥锁（MUTEX）和环境变量（cond）去控制线程的通讯，用起来挺麻烦的，用信号量（SEM）来通讯控制就方便多了！

用到信号量就要包含semaphore.h头文件。
能够用sem_t类型来声明一个型号量。

 
  #include <semaphore.h> sem_t * sem_open(const char *name, int oflag, ...);  
 

用 int sem_init(sem_t *sem, int pshared, unsigned int value) 函数来初始化型号量，第一个参数就是用 sem_t 声明的信号量，第二变量若是为０，表示这个信号量只是当前进程中的型号量，若是不为０，这个信号量可能能够在两个进程中共享。第三个参数就是初始化信号量的多少值。

sem_wait(sem_t *sem) 函数用于接受信号，当 sem > 0 时就能接受到信号，而后将 sem–;
sem_post(sem_t *sem) 函数能够增长信号量。
sem_destroy(sem_t *sem) 函数用于解除信号量。

如下是一个用信号控制的一个简单的例子:

#include <stdio.h>
#include <semaphore.h>
#include <pthread.h>

sem_t sem1, sem2;

void *thread1(void *arg) {
    sem_wait(&sem1);
    setbuf(stdout,NULL);//这里必须注意，因为下面输出"hello"中没有‘n’符，因此可能因为输出缓存已满，形成输不出东西来，因此用这个函数把输出缓存清空
    printf("hello ");
    sem_post(&sem2);
}

void *thread2(void *arg) {
    sem_wait(&sem2);
    printf("world!n");
}

int main() {
    pthread_t t1, t2;

    sem_init(&sem1,0,1);//初始化化信号量为1，因此会先打印线程1
    sem_init(&sem2,0,0);//初始化信号量为0

    pthread_create(&t1,NULL,thread1,NULL);
    pthread_create(&t2,NULL,thread2,NULL);

    pthread_join(t1,NULL);
    pthread_join(t2,NULL);

    sem_destroy(&sem1);
    sem_destroy(&sem2);

    return 0;
}

//程序的实现是控制先让thread1线程打印"hello "再让thread2线程打印"world!"

mutex互斥体只用于保护临界区的代码(访问共享资源),而不用于锁之间的同步，即一个线程释放mutex锁后，立刻又可能获取同一个锁，而无论其它正在等待该mutex锁的其它线程。

semaphore信号量除了起到保护临界区的做用外，还用于锁同步的功能，即一个线程释放semaphore后，会保证正在等待该semaphore的线程优先执行，而不会立刻在获取同一个semaphore。

若是两个线程想经过一个锁达到输出1,2,1,2,1,2这样的序列，应使用semaphore, 而使用 mutex 的结果可能为1,1,1,1,1,2,2,2,111…..。