1. 爱易网页
  2. Linux
  3. Linux平台上线程池的原理及实现

Linux平台上线程池的原理及实现

日期：2014-05-16　 浏览次数：20618 次

Linux平台下线程池的原理及实现
什么时候需要创建线程池呢？简单的说，如果一个应用需要频繁的创建和销毁线程，而任务执行的时间又非常短，这样线程创建和销毁的带来的开销就不容忽视，这时也是线程池该出场的机会了。如果线程创建和销毁时间相比任务执行时间可以忽略不计，则没有必要使用线程池了。

   下面是Linux系统下用C语言创建的一个线程池。线程池会维护一个任务链表(每个CThread_worker结构就是一个任务)。

   pool_init()函数预先创建好max_thread_num个线程，每个线程执thread_routine ()函数。该函数中

  1. while (pool->cur_queue_size == 0)
  2. {
  3.        pthread_cond_wait (&(pool->queue_ready),&(pool->queue_lock));
  4. }

表示如果任务链表中没有任务，则该线程出于阻塞等待状态。否则从队列中取出任务并执行。
   
   pool_add_worker()函数向线程池的任务链表中加入一个任务，加入后通过调用pthread_cond_signal (&(pool->queue_ready))唤醒一个出于阻塞状态的线程(如果有的话)。
   
   pool_destroy ()函数用于销毁线程池，线程池任务链表中的任务不会再被执行，但是正在运行的线程会一直把任务运行完后再退出。

下面贴出完整代码
  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <unistd.h>
  4. #include <sys/types.h>
  5. #include <pthread.h>
  6. #include <assert.h>

  8. /*
  9. *线程池里所有运行和等待的任务都是一个CThread_worker
  10. *由于所有任务都在链表里，所以是一个链表结构
  11. */
  12. typedef struct worker
  13. {
  14.     /*回调函数，任务运行时会调用此函数，注意也可声明成其它形式*/
  15.     void *(*process) (void *arg);
  16.     void *arg;/*回调函数的参数*/
  17.     struct worker *next;

  19. } CThread_worker;


  22. /*线程池结构*/
  23. typedef struct
  24. {
  25.      pthread_mutex_t queue_lock;
  26.      pthread_cond_t queue_ready;

  28.     

相关资料更多>

  1. red hat server 5.6 没有eth0解决方案
  2. 关于安装两个gcc的版本变换有关问题
  3. 装配Debian，使用syslinux引导U盘安装
  4. Linux上的Memcache安装
  5. CentOS配置好外网ip后，网卡也正常启动了，但是ping不通ip,该如何处理
  6. linux上头文件找不到
  7. Linux上让eclips支持gbk
  8. minicom 传送文件u-boot.bin到目标板ok6410,该怎么处理
  9. CentOS 6.2下编译Linux 3.2.13内核遇到异常