綫程池部分代碼實現筆記

計算機中常用的池（池式結構）

内存池

數據庫連接池

請求池

消息隊列（消息池）

對象池

緩衝區

綫程池解決問題

異步解耦的作用，如讀寫磁盤，檢測IO

綫程池三個部分

1 多個綫程s

2 多個任務

3 管理組件

綫程池部分代碼

#include<stdio.h>
#include <pthread.h>struct NWORKER
{pthread_t thread;struct NWORKER* pool;int terminate;struct NWORKER* prev;struct NWORKER* next;
};struct NJOB
{void (*func)(struct NJOB* job);void* user_data;struct NJOB * prev;struct NJOB * next;};struct NMANAGER
{struct NWORKER* workers;struct NJOB* jobs;pthread_cond_t jobs_cond;pthread_mutex_jobs_mutex;//任務隊列是臨界資源，綫程不能同時進行訪問
};//使用頭插法增加任務，
#define LL_ADD(item,list) do{
item->prev = NULL;
item->next = list;
list->prev = item;
list = item;
}while (0);#define LL_REMOVE(item,list) do{
if (item - < prev != NULL)item->prev->next = item->next;
if(item->prev!=NULL)item->next->prev = item->prev;
if (list == item)list = item->next;
item->prev = item->next = NULL;
}while (0);//靜態函數  只在本文件有效
static void* nThreadCallBack(void *arg)
{struct NWORKER* worker = (struct NWORKER) arg;while (1){//條件等待前加鎖pthread_mutex_lock(&worker->pool->jobs_mutex);while (worker->pool->jobs == NULL){//if (worker->terminate) break;pthread_cond_wait(worker->pool->jobs_cond, worker->pool->jobs_mutex);}if (worker->terminate){pthread_mutex_unlock(&worker->pool->jobs_mutex);}struct NJOB* job = worker->pool->jobs;LL_REMOVE(job,worker->pool->jobs);pthread_mutex_unlock(&worker->pool->jobs_mutex);job->func(job->user_data);}free(worker);pthread_exit(NULL);
}typedef struct NWORKER nThreadPool;
//綫程池初始化  numworkers 綫程數量
int nThreadPoolCreate(nThreadPool *pool, int numworkers)
{if (numworkers < 1) numworkers = 1;if (pool == NULL) return -1;memset(pool,0,sizeof(nThreadPool));//内存拷貝pthread_cond_t blank_cond = PTHREAD_COND_INITIALIZER;memcpy(&pool->jobs_cond, &blank_cond,sizeof(pthread_cond_t));pthread_mutex_t blank_mutex = PTHREAD_MUTEX_INITIALIZER;memcpy(&pool->jobs_mutex,&blank_mutex,sizeof(pthread_mutex_t)));int i = 0;for (int i = 0; i < numworkers; i++){struct NWORKER* worker = (struct NWORKER*) malloc(sizeof(struct NWORKER));if (worker == NULL){perror(*mallloc);return -2;}//一定要初始化memset(worker, 0, sizeof(struct WORKER));worker->pool = pool;int ret = pthread_create(worker->thread, NULL,nThreadCallBack,worker);if (ret) {perror("pthread_create");free("worker");return -3;}//每創建一個綫程 就把它加入綫程池LL_ADD(worker, pool->workers);}return pool;
}int nThreadPoolDestroy(nThreadPool* pool)
{struct NWORKER* worker = NULL;for (worker* pool->worker != NULL; worker = worker->next){worker->terminate = 1;}pthread_mutex_lock(&pool->jobs_mutex);pthread_cond_broadcast(pool->jobs_cond);pthread_mutex_unlock(&pool->jobs_mutex);
}void nThreadPoolPush(nThreadPool pool, struct NJOB *job)
{pthread_mutex_lock(&pool->jobs_mutex);LL_ADD(job, pool->jobs);pthread_cond_signal(&pool->jobs_cond);//喚醒其中一個綫程為其服務pthread_mutex_unlock(&pool->jobs_mutex);
}

綫程池部分代碼實現筆記相关推荐

latent_3d_points代碼付現：Learning Representations and Generative Models For 3D Point Clouds
第一步:geihub下載代碼 latent_3d_points:https://github.com/optas/latent_3d_points 第二:安裝環境 Ubuntu 16.04 Pytho ...
php 服務器連接,cocos2d-x網絡編程連接php服務器筆記4
VS工程部分----網絡編程本節會把最終實現代碼和資源放在文章最未提供各位下載學習. 本節我們開始重頭戲聯網功能的開發,我用的是cocos2d-x綁定的curl庫,這個curl據說很火,雖然我本人了 ...
Real-time hatching報告+實現代碼和效果
1.論文解讀論文標題為實時的畫影線,實時的畫影線的主要作用可以用於產生素描畫的效果.該論文屬於計算機圖形學中的圖像處理技術和紋理技術. 根據摘要,論文可以被分為四個部分.該論文通過分析已有技術中的問 ...
C#適應練習:幾種常見設計模式的實現
一.單例及原型模式單例:即使用一個固定對象的對象進行操作,實現起來很簡單 using System; using System.Collections.Generic; using System.L ...
ASP + Serv-u 實現FTP的代碼
ASP + Serv-u 實現FTP的代碼發佈者:[飛翔] 瀏覽:[ ] 評論:[0]  <% ' ...
開玩樹莓派（二）：配置IP，實現無顯示器局域網內Putty連接和RDP遠程
目錄: 開玩樹莓派(一):安裝Raspbian系統開玩樹莓派(二):配置IP,實現無顯示器局域網內Putty連接和RDP遠程開玩樹莓派(三):Python編程開玩樹莓派(四):GPIO控制和遠程 ...
linux 有名管道pipe,linux 用無名管道pipe和有名管道fifo實現線程間通信
1.pipe 用與實現同一個進程下不同線程間的通信(跟IPC進程間通信中的具有血緣關系的進程通信實現方式一樣) #include #include #include #include #include ...
应用调优常用技巧-線程池
应用调优常用技巧-線程池应用调优常用技巧 - 线程池線程池的好處核心API-操作類核心API-監控類 2-2 线程池BlockingQueue详解.选择与调优調優技巧 2-3 线程池Sche ...
mysql 开启 thread pool_MySQL線程池(THREAD POOL)的處理
背景介紹 MySQL常用(目前線上使用)的線程調度方式是one-thread-per-connection(每連接一個線程),server為每一個連接創建一個線程來服務,連接斷開后,這個線程進入thr ...

綫程池部分代碼實現筆記

綫程池部分代碼實現筆記相关推荐

最新文章

热门文章

綫程池 部分代碼實現 筆記

綫程池 部分代碼實現 筆記相关推荐

最新文章

热门文章

綫程池部分代碼實現筆記

綫程池部分代碼實現筆記相关推荐