diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/itoatom.h | 81 |
1 files changed, 41 insertions, 40 deletions
diff --git a/src/itoatom.h b/src/itoatom.h index 2791519..5d4db0e 100644 --- a/src/itoatom.h +++ b/src/itoatom.h | |||
| @@ -5,59 +5,60 @@ | |||
| 5 | * terms of the license contained in the file LICENSE. | 5 | * terms of the license contained in the file LICENSE. |
| 6 | */ | 6 | */ |
| 7 | 7 | ||
| 8 | #ifndef BU_ITO_QUEUE_H | 8 | #ifndef BU_ITO_ATOM_H |
| 9 | #define BU_ITO_QUEUE_H | 9 | #define BU_ITO_ATOM_H |
| 10 | 10 | ||
| 11 | #include <pthread.h> | 11 | #include <pthread.h> |
| 12 | 12 | ||
| 13 | #include "itomutex.h" | 13 | #include "itomutex.h" |
| 14 | #include "itocondition.h" | 14 | #include "itocondition.h" |
| 15 | 15 | ||
| 16 | /** | 16 | namespace Bu |
| 17 | * A thread-safe wrapper class. | ||
| 18 | *@ingroup Threading | ||
| 19 | */ | ||
| 20 | template <class T> | ||
| 21 | class ItoAtom | ||
| 22 | { | 17 | { |
| 23 | public: | ||
| 24 | /** | 18 | /** |
| 25 | * Construct an empty queue. | 19 | * A thread-safe wrapper class. |
| 20 | *@ingroup Threading | ||
| 26 | */ | 21 | */ |
| 27 | ItoAtom() | 22 | template <class T> |
| 23 | class ItoAtom | ||
| 28 | { | 24 | { |
| 29 | } | 25 | public: |
| 26 | /** | ||
| 27 | * Construct an empty queue. | ||
| 28 | */ | ||
| 29 | ItoAtom() | ||
| 30 | { | ||
| 31 | } | ||
| 30 | 32 | ||
| 31 | ItoAtom( const T &src ) : | 33 | ItoAtom( const T &src ) : |
| 32 | data( src ) | 34 | data( src ) |
| 33 | { | 35 | { |
| 34 | } | 36 | } |
| 35 | 37 | ||
| 36 | ~ItoQueue() | 38 | ~ItoAtom() |
| 37 | { | 39 | { |
| 38 | } | 40 | } |
| 39 | 41 | ||
| 40 | T get() | 42 | T get() |
| 41 | { | 43 | { |
| 42 | mOperate.lock(); | 44 | mOperate.lock(); |
| 43 | mOperate.unlock(); | 45 | T ret = data; |
| 44 | return data; | 46 | mOperate.unlock(); |
| 45 | } | 47 | return ret; |
| 48 | } | ||
| 46 | 49 | ||
| 47 | void set( const T &val ) | 50 | void set( const T &val ) |
| 48 | { | 51 | { |
| 49 | mOperate.lock(); | 52 | mOperate.lock(); |
| 50 | data = val; | 53 | data = val; |
| 51 | cBlock.signal(); | 54 | mOperate.unlock(); |
| 52 | mOperate.unlock(); | 55 | } |
| 53 | } | 56 | |
| 54 | 57 | private: | |
| 55 | private: | 58 | T data; |
| 56 | Item *pStart; /**< The start of the queue, the next element to dequeue. */ | 59 | |
| 57 | Item *pEnd; /**< The end of the queue, the last element to dequeue. */ | 60 | ItoMutex mOperate; /**< The master mutex, used on all operations. */ |
| 58 | 61 | }; | |
| 59 | ItoMutex mOperate; /**< The master mutex, used on all operations. */ | ||
| 60 | ItoCondition cBlock; /**< The condition for blocking dequeues. */ | ||
| 61 | }; | 62 | }; |
| 62 | 63 | ||
| 63 | #endif | 64 | #endif |
