glib 线程池 thread_pool

#include <stdio.h>
#include <glib.h>
#include <string.h>
/** 全局锁*/
GMutex g_lock;
#define MAX_THREAD_NUM 10
/**
* @brief 线程池回调函数，线程执行的主体函数
*/
void show_result(gpointer str, gpointer data)
{
g_mutex_lock(&g_lock);
printf("The result is : %sn", (char*)str);
g_mutex_unlock(&g_lock);
if(1)
{
g_printf("thread[%lu] is running...n",pthread_self());
sleep(10);
}
}
int main()
{
char *str = "thread_pool example";
int count = 0;
int g_thread_num = 0;
GThreadPool *thread_pool;
/**
* 初始化互斥锁，NULL表示使用默认的快速互斥锁。
*/
g_mutex_init(&g_lock);
thread_pool = g_thread_pool_new(show_result, NULL, MAX_THREAD_NUM, TRUE, NULL);
if (thread_pool == NULL)
{
printf("g_thread_pool_new failed!n");
return -1;
}
/**
* 调用20次线程池
* 实际线程池中最多有10个线程同时运行
*/
for (count; count < 20; count++)
{
g_thread_pool_push(thread_pool, (gpointer)str, NULL);
}
g_thread_num =
g_thread_pool_get_max_threads(thread_pool);
printf("Max number in the pthread pool: %dn", g_thread_num);
g_thread_pool_free(thread_pool, 0, 1);
return;
}

最后

以上就是体贴钻石为你收集整理的glib 线程池 thread_pool的全部内容，希望文章能够帮你解决glib 线程池 thread_pool所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。