mailbox.hpp

Go to the documentation of this file.

#pragma once
 
#include <functional>
#include <memory>
#include <mutex>
#include <queue>
 
#include <mapbox/std/weak.hpp>
 
namespace mbgl {
 
class Scheduler;
class Message;
 
class Mailbox : public std::enable_shared_from_this<Mailbox> {
public:
   
    Mailbox();
    
    Mailbox(Scheduler&);
 
    void open(Scheduler& scheduler_);
    void close();
 
    bool isOpen() const;
 
    void push(std::unique_ptr<Message>);
    void receive();
 
    static void maybeReceive(const std::weak_ptr<Mailbox>&);
    static std::function<void()> makeClosure(std::weak_ptr<Mailbox>);
 
private:
    mapbox::base::WeakPtr<Scheduler> weakScheduler;
 
    std::recursive_mutex receivingMutex;
    std::mutex pushingMutex;
 
    bool closed { false };
 
    std::mutex queueMutex;
    std::queue<std::unique_ptr<Message>> queue;
};
 
} // namespace mbgl