线性池的应用来源

  为满足多客户端可同时登陆的要求,服务器端必须实现并发工作方式当服务器主进程持续等待客户端连接时,每连接上一个客户端都需一个单独的进程或线程处理客户端的任务。但考虑到多进程对系统资源消耗大,单一线程存在重复创建、销毁等动作产生过多的调度开销,故采用线性池的方法。

  线性池是一种多线程并发的处理形式,它就是由一堆已创建好的线程组成。有新任务 -> 取出空闲线程处理任务 -> 任务处理完成放入线程池等待。避免了处理短时间任务时大量的线程重复创建、销毁的代价,非常适用于连续产生大量并发任务的场合。


  线行池实现原理过程:

1初始设置任务队列(链表)作为缓冲机制,并初始化创建n个线程加锁去任务队列取任务运行(多线程互斥)

2处理任务过程中,当任务队列为空时,所有线程阻塞(阻塞IO)处于空闲wait)状态;

3)当任务队列加入新的任务时,队列加锁,然后使用条件变量唤醒work)处于阻塞中的某一线程来执行任务

4)执行完后再次返回线程池中成为空闲wait)状态,依序或等待执行下一个任务。

  最后完成所有任务线程池中的线程统一销毁


  加入程序框架中:

main主函数下:
//1.初始化线程池
    pool_init(5);
//   等待连接
    while(1)
    {
        new_fd = accept(sockfd,(struct sockaddr *)(&client_addr),&sin_size);
        //2.执行process,将process任务交给线程池
        pool_add_task(process,new_fd);
    }

void pool_init (int max_thread_num)
{
pool->threadid = (pthread_t *) malloc (max_thread_num * sizeof (pthread_t)); //申请堆空间
    for (i = 0; i < max_thread_num; i++) //3
    {
        pthread_create (&(pool->threadid[i]), NULL, thread_routine, NULL); //创建线程  保存线程id
    }
}

int pool_add_task (void *(*process) (int arg), int arg)
{
/*构造一个新任务 初始化*/
    Cthread_task *task = (Cthread_task *) malloc (sizeof (Cthread_task));
    task->process = process;
    task->arg = arg;
    task->next = NULL;
    pthread_mutex_lock (&(pool->queue_lock));
~~~~~~
    pthread_mutex_unlock (&(pool->queue_lock));
    pthread_cond_signal (&(pool->queue_ready)); //唤醒线程
    return 0;
}

void * process(int arg)   //读取操作符,读取对应的命令响应
07-24 06:39