Thread.h

浏览该文件的文档.

#pragma once
 
#include "common/Module.h"
#include "thread/Channel.h"
#include "thread/JobSystem.h"
#include "thread/Task.h"
#include "thread/ThreadPool.h"
 
#include <map>
#include <memory>
#include <mutex>
#include <string>
 
namespace eve {
namespace thread {
 
class Thread : public Module {
public:
    Module_REG(Thread);
 
    Thread();
    ~Thread() override;
 
    int getHardwareConcurrency() const;
 
    ThreadPool *getPool();
 
    ThreadPool *newThreadPool(int workerCount = 0);
 
    JobSystem *getJobSystem();
 
    Channel *getChannel(std::string name);
 
    Channel *newChannel();
 
    void postMain(std::string name, std::string data = "");
 
private:
    std::mutex mu_;
    std::unique_ptr<ThreadPool> defaultPool_;
    std::unique_ptr<JobSystem> defaultJobSystem_;
    std::map<std::string, std::unique_ptr<Channel>> namedChannels_;
};
 
}  // namespace thread
}  // namespace eve