thread_pool.hpp

Go to the documentation of this file.

#ifndef LIBFILEZILLA_THREAD_POOL_HEADER
#define LIBFILEZILLA_THREAD_POOL_HEADER
 
#include "libfilezilla.hpp"
#include "mutex.hpp"
 
#include <functional>
#include <memory>
#include <vector>
 
namespace fz {
 
class thread_pool;
 
class async_task_impl;
 
class FZ_PUBLIC_SYMBOL async_task final {
public:
    async_task() = default;
 
    ~async_task();
 
    async_task(async_task const&) = delete;
    async_task& operator=(async_task const&) = delete;
 
    async_task(async_task && other) noexcept;
    async_task& operator=(async_task && other) noexcept;
 
    void join();
 
    explicit operator bool() const { return impl_ != nullptr; }
 
    void detach();
 
private:
    friend class thread_pool;
 
    async_task_impl* impl_{};
};
 
class pooled_thread_impl;
 
class FZ_PUBLIC_SYMBOL thread_pool final
{
public:
    thread_pool();
    ~thread_pool();
 
    thread_pool(thread_pool const&) = delete;
    thread_pool& operator=(thread_pool const&) = delete;
 
    async_task spawn(std::function<void()> const& f);
    async_task spawn(std::function<void()> && f);
 
private:
    FZ_PRIVATE_SYMBOL pooled_thread_impl* get_or_create_thread();
 
    friend class async_task;
    friend class pooled_thread_impl;
 
    std::vector<pooled_thread_impl*> threads_;
    std::vector<pooled_thread_impl*> idle_;
    mutex m_{false};
    bool quit_{};
};
 
}
 
#endif