README.md · innovatorzhang/ThreadPool - Gitee.com

12月28日，「开源中国源创会年终盛典」珠海站再次回归！点击免费报名参会

forked from Rocky/ThreadPool

加入 Gitee

与超过 1200万开发者一起发现、参与优秀开源项目，私有仓库也完全免费：）

文件

克隆/下载

README.md 1.36 KB

# 线程池项目说明

## 目录结构
```
thread-pool
|-- CMakeLists.txt # cmake工程管理文件
|-- example.cpp # 测试demo
|-- threadpool
    |-- CMakeLists.txt # cmake工程管理文件
    |-- Task.hpp # 线程池中允许的任务的抽象基类
    |-- TaskQueue.hpp # 任务队列的实现
    |-- ThreadPool.hpp/cpp # 线程池的实现
    |-- ThreadUtils.hpp # 线程工具函数，提取线程ID
    |-- WorkThread.hpp/cpp # 工作线程
```

## 使用
参照example.cpp代码
```cpp
#include <cstdio>
#include "ThreadPool.hpp"

// 定义字节的任务类，继承Task基类
class MyTask : public Task {
public:
    MyTask(int i) : Task("MyTask" + std::to_string(i)) {}
    
    // 实现Task类的Run函数，最终线程池里会调用该函数
    void Run()
    {
        for (int i = 0; i < 5; i++) {
            printf("-- thread [%3d]: task_name=[%20s], out=%d\n", GetThreadId(), GetName().c_str(), i);
            std::this_thread::sleep_for(std::chrono::seconds(1));
        }
    }
};

int main(int argc, char **argv) {
    ThreadPool pool;
    for (int i = 0; i < 50; i++) {
        pool.AddTask(std::make_shared<MyTask>(i));
    }
    int i = 100;
    while(i < 150) {
        pool.AddTask(std::make_shared<MyTask>(i));
        std::this_thread::sleep_for(std::chrono::seconds(1));
        i++;
    }
    pool.Finish(); // 记得终止线程池
    return 0;
}

```

一键复制编辑原始数据按行查看历史

提交于 2021-05-12 22:11 . 调整目录结构

# 线程池项目说明

## 目录结构
```
thread-pool
|-- CMakeLists.txt # cmake工程管理文件
|-- example.cpp # 测试demo
|-- threadpool
    |-- CMakeLists.txt # cmake工程管理文件
    |-- Task.hpp # 线程池中允许的任务的抽象基类
    |-- TaskQueue.hpp # 任务队列的实现
    |-- ThreadPool.hpp/cpp # 线程池的实现
    |-- ThreadUtils.hpp # 线程工具函数，提取线程ID
    |-- WorkThread.hpp/cpp # 工作线程
```

## 使用
参照example.cpp代码
```cpp
#include <cstdio>
#include "ThreadPool.hpp"

// 定义字节的任务类，继承Task基类
class MyTask : public Task {
public:
    MyTask(int i) : Task("MyTask" + std::to_string(i)) {}
    
    // 实现Task类的Run函数，最终线程池里会调用该函数
    void Run()
    {
        for (int i = 0; i < 5; i++) {
            printf("-- thread [%3d]: task_name=[%20s], out=%d\n", GetThreadId(), GetName().c_str(), i);
            std::this_thread::sleep_for(std::chrono::seconds(1));
        }
    }
};

int main(int argc, char **argv) {
    ThreadPool pool;
    for (int i = 0; i < 50; i++) {
        pool.AddTask(std::make_shared<MyTask>(i));
    }
    int i = 100;
    while(i < 150) {
        pool.AddTask(std::make_shared<MyTask>(i));
        std::this_thread::sleep_for(std::chrono::seconds(1));
        i++;
    }
    pool.Finish(); // 记得终止线程池
    return 0;
}

```

马建仓 AI 助手

尝试更多

代码解读

代码找茬

代码优化

1

https://gitee.com/innovatorzhang/thread-pool.git

git@gitee.com:innovatorzhang/thread-pool.git

innovatorzhang

thread-pool

ThreadPool

master