thread.hpp

Go to the documentation of this file.

 
#ifndef __JOIN_THREAD_HPP__
#define __JOIN_THREAD_HPP__
 
// C++.
#include <system_error>
#include <functional>
#include <memory>
#include <thread>
#include <atomic>
 
// C.
#include <pthread.h>
 
namespace join
{
    class Invoker
    {
    public:
        Invoker () = delete;
 
    private:
        template <class Function, class... Args>
        explicit Invoker (Function&& func, Args&&... args)
        : _func (std::bind (std::forward <Function> (func), std::forward <Args> (args)...)),
          _done (false)
        {
            pthread_attr_init (&_attr);
            pthread_create (&_handle, &_attr, _routine, this);
        }
 
    public:
        Invoker (const Invoker& other) = delete;
 
        Invoker& operator= (const Invoker& other) = delete;
 
        Invoker (Invoker&& other) = delete;
 
        Invoker& operator= (Invoker&& other) = delete;
 
        ~Invoker ();
 
    private:
        pthread_t handle ();
 
        static void * _routine (void * context);
 
        void * routine (void);
 
        std::function <void ()> _func;
 
        pthread_attr_t _attr;
 
        pthread_t _handle;
 
        std::atomic_bool _done;
 
        friend class Thread;
    };
 
    class Thread
    {
    public:
        Thread () noexcept = default;
 
        template <class Function, class... Args>
        explicit Thread (Function&& func, Args&&... args)
        : _invoker (new Invoker (std::forward <Function> (func), std::forward <Args> (args)...))
        {
        }
 
        Thread (const Thread& other) = delete;
 
        Thread& operator= (const Thread& other) = delete;
 
        Thread (Thread&& other) noexcept;
 
        Thread& operator= (Thread&& other) noexcept;
 
        ~Thread ();
 
        bool joinable () const noexcept;
 
        bool running () const noexcept;
 
        void join ();
 
        bool tryJoin ();
 
        void cancel ();
 
        void swap (Thread& other);
 
    private:
        std::unique_ptr <Invoker> _invoker;
    };
}
 
#endif