C++多线程，消息队列用法

      进程是没有活力的，它只是一个静态的概念。为了让进程完成一些工作，进程必须至少占有一个线程，所以线程是描述进程内的执行，正是线程负责执行包含在进程的地址空间中的代码。实际上，单个进程可以包含几个线程， 它们可以同时执行进程的地址空间中的代码。为了做到这一点，每个线程有自己的一组CPU寄存器和堆栈。

      线程是进程内部的一个执行单元。系统创建好进程后，实际上就启动执行了该进程的主执行线程，主执行线程以函数地址形式，比如说main或WinMain函数，将程序的启动点提供给Windows系统。主执行线程终止了，进程也就随之终止。

       每一个进程至少有一个主执行线程，它无需由用户去主动创建，是由系统自动创建的。用户根据需要在应用程序中创建其它线程，多个线程并发地运行于同一个进程中。一个进程中的所有线程都在该进程的虚拟地址空间中，共同使用这些虚拟地址空间、全局变量和系统资源，所以线程间的通讯非常方便，多线程技术的应用也较为广泛。

      多线程可以实现并行处理，避免了某项任务长时间占用CPU时间。要说明的一点是，目前大多数的计算机都是单处理器（CPU）的，为了运行所有这些线程，操作系统为每个独立线程安排一些CPU时间，操作系统以轮换方式向线程提供时间片，这就给人一种假象，好象这些线程都在同时运行。由此可见，如果两个非常活跃的线程为了抢夺对CPU的控制权，在线程切换时会消耗很多的CPU资源，反而会降低系统的性能。这一点在多线程编程时应该注意。
现代操作系统大都提供了相应的机制，用来处理线程的生存期、同步，以及其他“和线程有关”的属性，如优先级、线程专有存储空间（thread-specific storage）等。多线程编程是一门语言的难点和重点。

接下来让我们看看处理线程的函数：

pthread_create()函数，创建线程

函数原型如下：

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

参数讲解：

1、每个线程都有自己的ID即thread ID，可以简称tid，呵呵，是不是想起什么来了？。。。对，和pid有点象。其类型为pthread_t，pthread_t在头文件/usr/include/bits/pthreadtypes.h中定义：

         typedef unsigned long int pthread_t;

         可以看成是线程的标志符。当成功创建一个新线程的时候，系统会为该线程分配一个tid，并将该值通过指针返回给调用它的程序。

2、attr申明线程的属性。                       

     属性结构为pthread_attr_t，它在头文件/usr/include/pthread.h中定义。设为NULL，表示在这里我们只使用线程的默认属性就可以了。

    

3、start_routine表示新创建的线程所要执行的例程。线程以调用该函数开始，直到由该函数返回(return)终止这个线程，或者在start_routine所指向的函数中调用pthread_exit函数终止。start_routine只有一个参数，该参数由随后的arg指针来指出。

 

4、arg：也是一个指针，也就是start_routine指针所指向的函数的参数。

返回值：

  当pthread_create调用成功时，该调用返回0；否则，返回一个错误代码指出错误的类型。

pthread_exit()函数

线程的终止可以是调用了pthread_exit或者该线程的例程结束。也就是说，一个线程可以隐式的退出，也可以显式的调用pthread_exit函数来退出。

函数原型如下：

void pthread_exit( void * value_ptr );

线程的终止可以是调用了pthread_exit或者该线程的例程结束。也就是说，一个线程可以隐式的退出，也可以显式的调用pthread_exit函数来退出

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

pthread_join()函数，等待一个线程终止

调用pthread_join的线程将被挂起直到参数thread所代表的线程终止时为止。pthread_join是一个线程阻塞函数，调用它的函数将一直等到被等待的线程结束为止。

函数原型如下：

int pthread_join(pthread_t th, void **thread_return);

如果value_ptr不为NULL，那么线程thread的返回值存储在该指针指向的位置。该返回值可以是由pthread_exit给出的值，或者该线程被取消而返回PTHREAD_CANCELED。

当一个非分离的线程终止后，该线程的内存资源(线程描述符和栈)并不会被释放，直到有线程对它使用了pthread_join时才被释放。因此，必须对每个创建为非分离的线程调用一次pthread_join调用，以避免内存泄漏。否则当线程是可分离的，调用pthread_exit，将终止该调用线程，并释放所有资源，没有线程等待它终止。

至多只能有一个线程等待给定的线程终止。如果已经有一个线程在等待thread线程终止了，那么再次调用pthread_join等待同一线程的线程将返回一个错误

linux下多线程的实现方法：

1)使用全局变量  2)不使用全局变量   3)线程相关的数据

实例1

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

#define MAXLENGTH 20

void another_func(const char* threadName)
{
    printf("%s is running in another_func\n",threadName);
}

void * thread_func(void *args)
{
    char threadName[MAXLENGTH];
    strncpy(threadName,(char*)args,MAXLENGTH-1);

    printf("%s is running in thread_func\n",threadName);
    another_func(threadName);
}

int main(int argc,char* argv[])
{
    pthread_t pa,pb;
    pthread_create(&pa, NULL, thread_func, "Thread A");
    pthread_create(&pb, NULL, thread_func, "Thread B");

    pthread_join(pa, NULL);
    pthread_join(pb, NULL);
    return 0;
}

输出结果为:
Thread A is running in thread_func
Thread A is running in another_func
Thread B is running in thread_func
Thread B is running in another_func

该方法的缺点是:由于要记录是哪一个线程在调用函数,每个函数需要一个额外的参数来
记录线程的名字,例如another_func函数需要一个threadName参数
如果调用的函数多了,则每一个都需要一个这样的参数

实例2

#include <string.h>
#include <pthread.h>
#define MAXLENGTH 20

char threadName[MAXLENGTH];
pthread_mutex_t sharedMutex=PTHREAD_MUTEX_INITIALIZER;

void another_func ()
{
  printf ("%s is running in another_func\n", threadName);
}

void * thread_func (void * args)
{
  pthread_mutex_lock(&sharedMutex);
  strncpy (threadName, (char *)args, MAXLENGTH-1);
  printf ("%s is running in thread_func\n", threadName);
  another_func ();
  pthread_mutex_unlock(&sharedMutex);

}

int main (int argc, char * argv[])
{

  pthread_t pa, pb;
  pthread_create ( &pa, NULL, thread_func, "Thread A");
  pthread_create ( &pb, NULL, thread_func, "Thread B");

  pthread_join (pa, NULL);
  pthread_join (pb, NULL);
}

该方法的缺点是:由于多个线程需要读写全局变量threadName,就需要使用互斥机制

分析以上两种实现方法,Thread-Specific Data "线程相关的数据"的一个好处就体现出来了:

(1)"线程相关的数据"可以是一个全局变量,并且

(2)每个线程存取的"线程相关的数据"是相互独立的.

实例3

#include <string.h>
#include <pthread.h>

pthread_key_t p_key;

void another_func ()
{
  printf ("%s is running in another_func\n", (char *)pthread_getspecific(p_key));
}

void * thread_func (void * args)
{
  pthread_setspecific(p_key, args);
  printf ("%s is running in thread_func\n", (char *)pthread_getspecific(p_key));
  another_func ();

}

int main (int argc, char * argv[])
{

  pthread_t pa, pb;

  pthread_key_create(&p_key, NULL);

  pthread_create ( &pa, NULL, thread_func, "Thread A");
  pthread_create ( &pb, NULL, thread_func, "Thread B");

  pthread_join (pa, NULL);
  pthread_join (pb, NULL);
}

线程互斥

互斥操作，就是对某段代码或某个变量修改的时候只能有一个线程在执行这段代码，其他线程不能同时进入这段代码或同时修改该变量。这个代码或变量称为临界资源。

例如：有两个线程A和B，临界资源为X，首先线程A进入，将X置为加锁状态，在A将锁打开之前的这段时间里，如果此时恰巧线程B也欲获得X，但它发现X处于加锁状态，说明有其它线程正在执行互斥部分，于是，线程B将自身阻塞。。。线程A处理完毕，在退出前，将X解锁，并将其它线程唤醒，于是线程B开始对X进行加锁操作了。通过这种方式，实现了两个不同线程的交替操作。

一个互斥体永远不可能同时属于两个线程。或者处于锁定状态；或者空闲中，不属于任何一个线程。

实例1

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

void * pthread_func_test(void * arg);

pthread_mutex_t mu;

int main()
{
    int i;
    pthread_t pt;

    pthread_mutex_init(&mu,NULL);        //声明mu使用默认属性，此行可以不写
    pthread_create(&pt,NULL,pthread_func_test,NULL);
    for(i = 0; i < 3; i++)
    {
        pthread_mutex_lock(&mu);
        printf("主线程ID是：%lu  ",pthread_self());        //pthread_self函数作用：获得当前线程的id
        pthread_mutex_unlock(&mu);
        sleep(1);
    }
}

void * pthread_func_test(void * arg)
{
    int j;
    for(j = 0; j < 3; j++)
    {
        pthread_mutex_lock(&mu);
        printf("新线程ID是：%lu  ",pthread_self());
        pthread_mutex_unlock(&mu);
        sleep(1);
    }
}

终端输出结果：

主线程ID是 : 3086493376

新线程ID是 : 3086490512

主线程ID是 : 3086493376

新线程ID是 : 3086490512

主线程ID是 : 3086493376

新线程ID是 : 3086490512

pthread_mutex_lock声明开始用互斥锁上锁，此后的代码直至调用pthread_mutex_unlock为止，都处于加锁状态中，即同一时间只能被一个线程调用执行。当另一个线程执行到pthread_mutex_lock处时，如果该锁此时被其它线程使用，那么该线程被阻塞，即程序将等待到其它线程释放此互斥锁。

pthread_mutex_init()函数  作用：初始化互斥体类型变量mutex，变量的属性由attr进行指定。attr设为NULL，即采用默认属性，这种方式与pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER的方式等价。

函数原型如下：

int pthread_mutex_lock(pthread_mutex_t *mutex);

pthread_mutex_unlock()函数  作用：如果当前的线程拥有参数mutex所指定的互斥体，那么该函数调用将该互斥体解锁。

函数原型如下：

int pthread_mutex_unlock(pthread_mutex_t *mutex);

pthread_mutex_destroy()函数  作用：用来释放互斥体所占用的资源。

函数原型如下：

int pthread_mutex_destroy(pthread_mutex_t *mutex);

pthread_self()函数  作用：获得线程自身的ID。前面我们已经提到过，pthread_t的类型为unsigned long int，所以在打印的时候要使用%lu方式，否则将产生奇怪的结果。

函数原型如下：

pthread_t pthread_self(void);

但是上面的代码并不完善，假设将循环次数修改得足够的长，打印后的结果可能并不是我们所希望看到的交替打印，可能象下面这样：

主线程ID是 : 3086493376

新线程ID是 : 3086490512

 

主线程ID是 : 3086493376

新线程ID是 : 3086490512

新线程ID是 : 3086490512

主线程ID是 : 3086493376

这是什么原因呢？因为Linux是分时操作系统，采用的是时间片轮转的方式，主线程和新线程可能因为其它因素的干扰，获得了非顺序的时间片。如果想要严格的做到“交替”方式，可以略施小计，即加入一个标志。

实例1

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

void * pthread_func_test(void * arg);

pthread_mutex_t mu;
int flag = 0;

int main()
{
    int i;
    pthread_t pt;

    pthread_mutex_init(&mu,NULL);
    pthread_create(&pt,NULL,pthread_func_test,NULL);
    for(i = 0; i < 3; i++)
    {
        pthread_mutex_lock(&mu);
        if(flag == 0)
                printf("主线程ID是：%lu  ",pthread_self());
        flag = 1;
        pthread_mutex_unlock(&mu);
        sleep(1);
    }
    pthread_join(pt, NULL);
    pthread_mutex_destroy(&mu);
}

void * pthread_func_test(void * arg)
{
    int j;
    for(j = 0; j < 3; j++)
    {
        pthread_mutex_lock(&mu);
        if(flag == 1)
            printf("新线程ID是：%lu  ",pthread_self());
        flag == 0;
        pthread_mutex_unlock(&mu);
        sleep(1);
    }
}

在使用互斥锁的过程中很有可能会出现死锁：即两个线程试图同时占用两个资源，并按不同的次序锁定相应的互斥锁，例如两个线程都需要锁定互斥锁1和互斥锁2，A线程先锁定互斥锁1，B线程先锁定互斥锁2，这时就出现了死锁。此时我们可以使用函数pthread_mutex_trylock，该函数企图锁住一个互斥体，但不阻塞

pthread_mutex_trylock()函数 作用：函数thread_mutex_trylock()用来锁住参数mutex所指定的互斥体。如果参数mutex所指的互斥体已经被上锁，该调用不会阻塞等待互斥体的解锁，而会返回一个错误代码。通过对返回代码的判断，程序员就可以针对死锁做出相应的处理。所以在对多个互斥体编程中，尤其要注意这一点。

函数原型如下：

int pthread_mutex_trylock(pthread_mutex_t *mutex);

线程同步

 

首先来看一下有关同步机制的概念。同步就是若干个线程等待某个事件的发生，当等待事件发生时，一起开始继续执行。可以这样简单理解同步，就是若干个线程各自对自己的数据进行处理，然后在某个点必须汇总一下数据，否则不能进行下一步的处理工作。

线程同步的函数调用有pthread_cond_init、pthread_cond_broadcast、pthread_cond_signal、pthread_cond_wait和pthread_cond_destroy

pthread_cond_init()函数  函数说明：按attr指定的属性初始化cond条件变量。如果attr为NULL，效果等同于pthread_cond_t cond = PTHREAD_COND_INITIALIZER

函数原型如下：

int pthread_cond_init(pthread_cond_t *restrict cond,
          const pthread_condattr_t *restrict attr);

pthread_cond_broadcast()函数 函数说明：对所有等待cond这个条件变量的线程解除阻塞。

函数原型如下：

int pthread_cond_broadcast(pthread_cond_t *cond);

pthread_cond_signal()函数  函数说明：仅仅解除等待cond这个条件变量的某一个线程的阻塞状态。如果有若干线程挂起等待该条件变量，该调用只唤起一个线程，被唤起的线程是哪一个是不确定的。

函数原型如下：

int pthread_cond_signal(pthread_cond_t *cond);

pthread_cond_wait()函数 函数说明：该调用自动阻塞发出调用的当前线程，并等待由参数cond指定的条件变量，而且为参数mutex指定的互斥体解锁。被阻塞线程直到有其他线程调用pthread_cond_signal或pthread_cond_broadcast函数置相应的条件变量时，而且获得mutex互斥体才解除阻塞。等待状态下的线程不占用CPU时间。

函数原型如下：

int pthread_cond_wait(pthread_cond_t *restrict cond,
       pthread_mutex_t *restrict mutex);

pthread_cond_timedwait()函数  函数说明：该函数自动阻塞当前线程等待参数cond指定的条件变量，并为参数mutex指定的互斥体解锁。被阻塞的线程被唤起继续执行的条件是：有其他线程对条件变量cond调用pthread_cond_signal函数；或有其他线程对条件变量cond调用pthread_cond_broadcast；或系统时间到达abstime参数指定的时间；除了前面三个条件中要有一个被满足外，还要求该线程获得参数mutex指定的互斥体。

函数原型如下：

int pthread_cond_timedwait(pthread_cond_t *restrict cond,
       pthread_mutex_t *restrict mutex,
       const struct timespec *restrict abstime);

pthread_cond_destroy()函数 函数说明：释放cond条件变量占用的资源。

函数原型如下：

int pthread_cond_destroy(pthread_cond_t *cond);

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

pthread_t pt1,pt2;
pthread_mutex_t mu;
pthread_cond_t cond;
int i = 1;

void * decrease(void * arg)
{
    while(1)
    {
        pthread_mutex_lock(&mu);
        if(++i)
        {
            printf("%d  ",i);
            if(i != 1)    printf("Error  ");
            pthread_cond_broadcast(&cond);
            pthread_cond_wait(&cond,&mu);
        }
        sleep(1);
        pthread_mutex_unlock(&mu);
    }
}

void * increase(void * arg)
{
    while(1)
    {
        pthread_mutex_lock(&mu);
        if(i--)
        {
            printf("%d  ",i);
            if(i != 0)    printf("Error  ");
            pthread_cond_broadcast(&cond);
            pthread_cond_wait(&cond,&mu);
        }
        sleep(1);
        pthread_mutex_unlock(&mu);
    }
}


int main()
{
    pthread_create(&pt2,NULL,increase,NULL);
    pthread_create(&pt1,NULL,decrease,NULL);
    pthread_join(pt1,NULL);
    pthread_join(pt2,NULL);
}