FactoryCraft-Server/FactoryCraft/TickQueue.h

#pragma once

#include <Array.h>
#include <condition_variable>
#include <ReferenceCounter.h>

class Block;

class TickQueue : public virtual Framework::ReferenceCounter
{
private:
    int maxSize;
    int readPosition;
    int writePosition;
    Block** queue;
    std::mutex mutex;
    std::condition_variable hasBlocks;
    std::condition_variable hasNoBlocks;
    bool exit;

public:
    TickQueue();
    ~TickQueue();

    void startNextTick(Framework::Array<Block*>* zSources);
    void addToQueue(Block* zBlock);
    Block* zNextBlock(bool& waiting);
    void requestExit();
    void waitForEmpty();
    void postTick();
};