linux+c线程池开源

#include <pthreadpool.h>
#include <stdio.h>

void* task(void* arg) {
    printf("Task executed by thread %ld\n", pthread_self());
    return NULL;
}

int main() {
    pthreadpool_t pool = pthreadpool_create(4); // 创建一个包含4个线程的线程池
    for (int i = 0; i < 8; ++i) {
        pthreadpool_add_task(pool, task, NULL); // 添加任务到线程池
    }
    pthreadpool_wait(pool); // 等待所有任务完成
    pthreadpool_destroy(pool); // 销毁线程池
    return 0;
}

#include "ThreadPool.h"
#include <stdio.h>

void* task(void* arg) {
    printf("Task executed by thread %ld\n", pthread_self());
    return NULL;
}

int main() {
    ThreadPool* pool = threadpool_init(4); // 创建一个包含4个线程的线程池
    for (int i = 0; i < 8; ++i) {
        threadpool_add_task(pool, task, NULL); // 添加任务到线程池
    }
    threadpool_wait(pool); // 等待所有任务完成
    threadpool_destroy(pool); // 销毁线程池
    return 0;
}

#include <uv.h>
#include <stdio.h>

void task_cb(uv_work_t* req) {
    printf("Task executed by thread %ld\n", pthread_self());
}

int main() {
    uv_loop_t* loop = uv_default_loop();
    uv_work_t req;
    uv_queue_work(loop, &req, NULL, task_cb); // 添加任务到线程池
    uv_run(loop, UV_RUN_DEFAULT); // 运行事件循环
    return 0;
}