[go: up one dir, main page]

Skip to content
This repository has been archived by the owner on Sep 27, 2020. It is now read-only.

fogti/ThreadPool

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

70 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

ThreadPool pipeline status

A simple C++17 Thread Pool implementation. This library uses meson as the build system and installs a library + pkg-config-file.

Basic usage:

// create thread pool with 4 worker threads
ThreadPool pool(4);

// enqueue and store future
auto result = pool.enqueue([](int answer) { return answer; }, 42);

// get result from future
std::cout << result.get() << std::endl;

Simple example program:

#include <iostream>
#include <vector>
#include <chrono>

#include "ThreadPool.hpp"

int main()
{
    ThreadPool pool(4);
    std::vector< std::future<int> > results;

    for(int i = 0; i < 8; ++i) {
        results.emplace_back(
            pool.enqueue([i] {
                std::cout << "hello " << i << std::endl;
                std::this_thread::sleep_for(std::chrono::seconds(1));
                std::cout << "world " << i << std::endl;
                return i*i;
            })
        );
    }

    for(auto && result: results)
        std::cout << result.get() << ' ';
    std::cout << std::endl;

    return 0;
}

About

A simple C++ Thread Pool implementation - fork of https://github.com/progschj/ThreadPool

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published