Asynchronous queue allowing the exchange of information between threads. More...
#include <arcane/parallel/thread/IAsyncQueue.h>
Public Member Functions | |
| virtual void | push (void *v)=0 |
| Adds v to the queue. | |
| virtual void * | pop ()=0 |
| Retrieves the first value from the queue and blocks if there are none. | |
| virtual void * | tryPop ()=0 |
| Retrieves the first value if available. Returns nullptr otherwise. | |
Static Public Member Functions | |
| static IAsyncQueue * | createQueue () |
Asynchronous queue allowing the exchange of information between threads.
Definition at line 32 of file IAsyncQueue.h.
|
static |
Definition at line 128 of file AsyncQueue.cc.
|
pure virtual |
Retrieves the first value from the queue and blocks if there are none.
Implemented in Arcane::MessagePassing::SharedMemoryBasicAsyncQueue.
|
pure virtual |
Adds v to the queue.
Implemented in Arcane::MessagePassing::SharedMemoryBasicAsyncQueue.
|
pure virtual |
Retrieves the first value if available. Returns nullptr otherwise.
Implemented in Arcane::MessagePassing::SharedMemoryBasicAsyncQueue.