线程解析（三）

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

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

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

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

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

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 entern");

pthread_mutex_lock(&mutex);

printf("mutex lockn");

sleep(10);

pthread_mutex_unlock(&mutex);

printf("mutex unlockn");

}

void *thread_b(void *arg)

{

printf("thread b entern");

while(pthread_mutex_trylock(&mutex))

{

printf("pthread trylockn");

sleep(1);

}

printf("mutex lockn");

pthread_mutex_unlock(&mutex);

printf("mutex unlockn");

}

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 closen");

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的用处及几个相关函数的使用方法。

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