FilesExpand file tree

 master

/

stdqueue.h

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

47 lines (38 loc) · 1.09 KB

 master

/

stdqueue.h

Copy path

Top

File metadata and controls

• Code
• Blame

47 lines (38 loc) · 1.09 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

// ©2014 Cameron Desrochers.

#pragma once

#include <queue>

#include "wrappers.h"

// Simple wrapper around std::queue (not thread safe)

template<typename T>

class StdQueueWrapper

{

public:

typedef DummyToken producer_token_t;

typedef DummyToken consumer_token_t;

public:

template<typename U>

inline bool enqueue(U&& item)

{

q.push(std::forward<U>(item));

return true;

}

inline bool try_dequeue(T& item)

{

if (q.empty()) {

return false;

}

item = std::move(q.front());

q.pop();

return true;

}

// Dummy token methods (not used)

bool enqueue(producer_token_t const&, T const&) { return false; }

bool try_enqueue(producer_token_t, T const&) { return false; }

bool try_dequeue(consumer_token_t, T& item) { return false; }

template<typename It> bool enqueue_bulk(It, size_t) { return false; }

template<typename It> bool enqueue_bulk(producer_token_t const&, It, size_t) { return false; }

template<typename It> size_t try_dequeue_bulk(It, size_t) { return 0; }

template<typename It> size_t try_dequeue_bulk(consumer_token_t, It, size_t) { return 0; }

private:

std::queue<T> q;

};