lang/html/_q_c___queue_8dox_8h_source.html

namespace Qore {

namespace Thread {


class Queue {


public:


nothing clear();


public:


 clearError();


public:


 constructor(int max = -1);


public:

/***/

 copy();


public:


 destructor();


public:


bool empty();


public:


auto get(timeout timeout_ms = 0);


public:


int getReadWaiting();


public:


int getWaiting();


public:


int getWriteWaiting();


public:


nothing insert(auto arg, timeout timeout_ms = 0);


public:


int max();


public:


auto pop(timeout timeout_ms = 0);


public:


nothing push(auto arg, timeout timeout_ms = 0);


public:


 setError(string err, string desc);


public:


int size();

};

}

}

Qore::Thread::Queue
Queue objects provide a blocking, thread-safe message-passing object to Qore programs
Definition: QC_Queue.dox.h:22

Qore::Thread::Queue::get
auto get(timeout timeout_ms=0)
Blocks until at least one entry is available on the queue, then returns the first entry in the queue....

Qore::Thread::Queue::destructor
destructor()
Destroys the Queue object.

Qore::Thread::Queue::size
int size()
Returns the number of elements in the Queue.

Qore::Thread::Queue::getWaiting
int getWaiting()
Returns the number of threads currently blocked on this queue for reading.

Qore::Thread::Queue::pop
auto pop(timeout timeout_ms=0)
Blocks until at least one entry is available on the queue, then returns the last entry in the queue....

Qore::Thread::Queue::clear
nothing clear()
Clears the Queue of all data.

Qore::Thread::Queue::clearError
clearError()
clears the error setting from the Queue; if error information is set, then after this call,...

Qore::Thread::Queue::max
int max()
Returns the upper limit of the number of elements in the Queue.

Qore::Thread::Queue::push
nothing push(auto arg, timeout timeout_ms=0)
Pushes a value on the end of the queue.

Qore::Thread::Queue::getReadWaiting
int getReadWaiting()
Returns the number of threads currently blocked on this queue for reading.

Qore::Thread::Queue::setError
setError(string err, string desc)
sets an error status on the Queue and clears the Queue; while a Queue object has an error status,...

Qore::Thread::Queue::constructor
constructor(int max=-1)
Creates the Queue object.

Qore::Thread::Queue::getWriteWaiting
int getWriteWaiting()
Returns the number of threads currently blocked on this queue for writing.

Qore::Thread::Queue::empty
bool empty()
Returns True if the Queue is empty, False if not.

Qore::Thread::Queue::copy
copy()
Creates a new Queue object with the same elements and maximum size as the original.

Qore::Thread::Queue::insert
nothing insert(auto arg, timeout timeout_ms=0)
Inserts a value at the beginning of the queue.

Qore
Qore namespace.
Definition: QC_AbstractSmartLock.dox.h:2