Channel.h

浏览该文件的文档.

#pragma once
 
#include <condition_variable>
#include <memory>
#include <mutex>
#include <queue>
#include <string>
 
namespace eve {
namespace thread {
 
class Channel {
public:
    Channel();
    explicit Channel(std::string name);
    ~Channel();
 
    std::string getName() const;
 
    void push(std::string value);
    std::string pop();
    std::string demand();
    std::string supply(int timeoutMs);
 
    bool hasData() const;
    int getCount() const;
    void clear();
 
private:
    struct State {
        explicit State(std::string channelName = {}) : name(std::move(channelName)) {}
 
        std::string name;
        mutable std::mutex mu;
        std::condition_variable cv;
        std::queue<std::string> queue;
    };
 
    std::shared_ptr<State> state_;
 
    friend class ThreadPool;
};
 
}  // namespace thread
}  // namespace eve