C++中如何利用线程池库进行任务调度

在 C++ 中，可以使用线程池库来进行任务调度。这里我们将介绍一个简单的线程池库，并展示如何使用它来调度任务。

首先，需要安装线程池库。在 Ubuntu 系统下，可以通过以下命令安装：

sudo apt-get install libboost-all-dev

接下来，创建一个名为 thread_pool.cpp 的文件，然后编写以下代码：

#include<
    iostream>
    
#include<
    boost/asio.hpp>
    
#include<
    boost/bind.hpp>
    
#include<
    boost/thread.hpp>


class ThreadPool {

public:
    ThreadPool(size_t num_threads) : work_(io_service_) {
    
        for (size_t i = 0;
     i <
     num_threads;
 ++i) {
    
            threads_.create_thread(boost::bind(&
    boost::asio::io_service::run, &
    io_service_));

        }

    }


    ~ThreadPool() {
    
        io_service_.stop();
    
        threads_.join_all();

    }
    

    template<
    typename F>

    void enqueue(F f) {
    
        io_service_.post(f);

    }
    

private:
    boost::asio::io_service io_service_;
    
    boost::asio::io_service::work work_;
    
    boost::thread_group threads_;

}
    ;


void task1() {
    
    std::cout <
    <
     "Task 1 is running in thread "<
    <
     boost::this_thread::get_id()<
    <
     std::endl;

}


void task2() {
    
    std::cout <
    <
     "Task 2 is running in thread "<
    <
     boost::this_thread::get_id()<
    <
     std::endl;

}


int main() {
    
    ThreadPool pool(4);
     // 创建一个包含 4 个线程的线程池

    pool.enqueue(task1);
     // 将任务 1 添加到线程池
    pool.enqueue(task2);
     // 将任务 2 添加到线程池

    return 0;

}
    

在这个例子中，我们创建了一个名为 ThreadPool 的类，它使用 boost::asio::io_service 和 boost::thread_group 来管理线程。ThreadPool 类提供了一个 enqueue 方法，用于将任务添加到线程池。

我们定义了两个简单的任务 task1 和 task2，并在 main 函数中创建了一个包含 4 个线程的线程池。然后，我们将这两个任务添加到线程池中。

要编译这个程序，请使用以下命令：

g++ -o thread_pool thread_pool.cpp -lboost_system -lboost_thread -pthread

最后，运行生成的可执行文件：

./thread_pool

输出结果类似于：

Task 1 is running in thread 140396678533888
Task 2 is running in thread 140396678533376

这表明任务已经在线程池中的线程上运行。

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！