线程解析（三）

　　作者：曹忠明，华清远见嵌入式学院讲师。

　　前面我们说了线程的创建和撤销，这里我们说一下线程间的同步的问题。

　　当同一个进程中存在多个线程的时候，多个线程共享相同的内存，确保每个线程能够看到一致的数据视图，如果每个线程中都不会读取或修改共同享有的变量，就不会存在一致性的问题，同样如果共享变量时只读的也就不会存在这个问题。但是，当某个线程可一个修改变量，而其他的线程去读取或修改这个变量的时候，就需要进行线程间的同步，确保他们访问变量的内容时不会访问到无效的数据。

　　这里介绍一种实现同步的方法：互斥量

　　互斥锁本质上是一把锁，在访问共享资源的时候对互斥量进行加锁，访问结束后解锁。在这里我们说一下如何去操作互斥锁。

　　1、 创建和撤销

　　互斥量用pthread_mutex_t数据类型来表示，在使用之前必须对其进行初始化，用完之后释放内存。互斥量初始化可以用PTHREAD_MUTEX_INITIALIZER来初始化(静态初始化)，亦可以使用pthread_mutex_init函数来实现，这种方法动态的为互斥量分配内存，使用后必须使用pthread_mutex_destroy来释放内存单元。下面是这些函数的原型：

　　pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

　　int pthread_mutex_init(pthread_mutex_t *restrict mutex,

　　const pthread_mutexattr_t *restrict attr);

　　int pthread_mutex_destroy(pthread_mutex_t *mutex);

　　2、 锁操作

　　锁操作主要包括加锁pthread_mutex_lock()、解锁pthread_mutex_unlock()和测试锁pthread_mutex_trylock()三个。通过pthread_mutex_lock对互斥量加锁，这里需要获得锁，如果无法获得锁则调用线程将阻塞到其他线程调用pthread_mutex_unlock对互斥量解锁。

　　int pthread_mutex_lock(pthread_mutex_t *mutex);

　　int pthread_mutex_trylock(pthread_mutex_t *mutex);

　　int pthread_mutex_unlock(pthread_mutex_t *mutex);

　　如果线程不希望被阻塞，则可以调用pthread_mutex_trylock尝试对互斥量进行加锁，当互斥量没有被加锁，则函数返回0，并锁住互斥量，否则会失败，返回EBUSY.

　　3、 示例

　　下面我们用一个例程说明一下这些函数的使用。

　　#include <stdio.h>

　　#include <pthread.h>

　　pthread_mutex_t mutex;

　　void *thread_a(void *arg)

　　{

　　printf("thread a enter\n");

　　pthread_mutex_lock(&mutex);

　　printf("mutex lock\n");

　　sleep(10);

　　pthread_mutex_unlock(&mutex);

　　printf("mutex unlock\n");

　　}

　　void *thread_b(void *arg)

　　{

　　printf("thread b enter\n");

　　while(pthread_mutex_trylock(&mutex))

　　{

　　printf("pthread trylock\n");

　　sleep(1);

　　}

　　printf("mutex lock\n");

　　pthread_mutex_unlock(&mutex);

　　printf("mutex unlock\n");

　　}

　　int main(int argc, char **argv)

　　{

　　pthread_t tid_a,tid_b;

　　int err;

　　if(pthread_mutex_init(&mutex, NULL) != 0)

　　{

　　perror("pthread_mutex_init");

　　}

　　err = pthread_create(&tid_a,NULL,thread_a,NULL);

　　if(err < 0)

　　{

　　perror("pthread_create thread_a");

　　}

　　sleep(1);

　　err = pthread_create(&tid_b,NULL,thread_b,NULL);

　　if(err < 0)

　　{

　　perror("pthread_create thread_a");

　　}

　　sleep(20);

　　printf("the main close\n");

　　return 0;

　　}

　　结果：

　　thread a enter

　　mutex lock

　　thread b enter

　　pthread trylock

　　pthread trylock

　　pthread trylock

　　pthread trylock

　　pthread trylock

　　pthread trylock

　　pthread trylock

　　pthread trylock

　　pthread trylock

　　mutex unlock

　　mutex lock

　　mutex unlock

　　the main close

　　由这里的结果可以看出mutex的用处及几个相关函数的使用方法。

　　“本文由华清远见https://www.embedu.org/index.htm提供”