File: clConcurrent.hpp

package info (click to toggle)
codelite 17.0.0%2Bdfsg-1
  • links: PTS, VCS
  • area: main
  • in suites: bookworm
  • size: 136,204 kB
  • sloc: cpp: 491,547; ansic: 280,393; php: 10,259; sh: 8,930; lisp: 7,664; vhdl: 6,518; python: 6,020; lex: 4,920; yacc: 3,123; perl: 2,385; javascript: 1,715; cs: 1,193; xml: 1,110; makefile: 804; cobol: 741; sql: 709; ruby: 620; f90: 566; ada: 534; asm: 464; fortran: 350; objc: 289; tcl: 258; java: 157; erlang: 61; pascal: 51; ml: 49; awk: 44; haskell: 36
file content (31 lines) | stat: -rw-r--r-- 740 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
#ifndef CLCONCURRENT_HPP
#define CLCONCURRENT_HPP

#include "codelite_exports.h"

#include <atomic>
#include <functional>
#include <thread>
#include <vector>
#include <wx/msgqueue.h>

class WXDLLIMPEXP_CL clConcurrent
{
    typedef std::function<void()> Callback;
    std::vector<std::thread*> m_thread_pool;
    size_t m_pool_size = 1;
    wxMessageQueue<Callback> m_queue;
    std::atomic_bool m_shutdown;

public:
    clConcurrent(size_t pool_size = 1);
    virtual ~clConcurrent();

    void run();
    void shutdown();
    void set_pool_size(size_t size) { m_pool_size = size; }
    bool is_running() const { return !m_thread_pool.empty(); }
    void queue(Callback callback) { m_queue.Post(callback); }
};

#endif // CLCONCURRENT_HPP