FilesExpand file tree

 master

/

synchronized_queue.hpp

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

57 lines (43 loc) · 1.3 KB

 master

/

synchronized_queue.hpp

Copy path

Top

File metadata and controls

• Code
• Blame

57 lines (43 loc) · 1.3 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

48

49

50

51

52

53

54

55

#ifndef SYNCHRONIZED_QUEUE_HPP

#define SYNCHRONIZED_QUEUE_HPP

#include <queue>

#include "pthread_tools.hpp"

// From graphlab

namespace graphchi {

template <typename T>

class synchronized_queue {

public:

synchronized_queue() { };

~synchronized_queue() { };

void push(const T &item) {

_queuelock.lock();

_queue.push(item);

_queuelock.unlock();

}

bool safepop(T * ret) {

_queuelock.lock();

if (_queue.size() == 0) {

_queuelock.unlock();

return false;

}

*ret = _queue.front();

_queue.pop();

_queuelock.unlock();

return true;

}

T pop() {

_queuelock.lock();

T t = _queue.front();

_queue.pop();

_queuelock.unlock();

return t;

}

size_t size() const{

return _queue.size();

}

private:

std::queue<T> _queue;

spinlock _queuelock;

};

}

#endif