multiqueue.h

#ifndef MULTIQUEUE_H
#define MULTIQUEUE_H
#include "particle.h"
#include "node.h"
#include <mutex>
#include <condition_variable>

class MultiQueue
{   
public:

    MultiQueue();
    ~MultiQueue();

    int getSize();
    std::mutex* getPositionMutex();
    std::condition_variable* getQueueNotFull();

    Node* getHead();
    Node* getTail();
    Node* getNthInstance(int n, Particle* p);
    Node* popNthInstance(int n, Particle* p);
    Node* popFirstInstance(Particle* p);
    Node* getTimestepN(int n, Particle* p);
    Node* popTimestepN(int n, Particle* p);
    Node* pop();

    void pushHead(Node*);
    void pushTail(Node*);

private:
    Node* head;
    Node* tail;
    int size;

    std::mutex positionMutex;
    std::condition_variable queueNotFull;

};

#endif // MULTIQUEUE_H