Class FiberQueue#

Class Documentation#

class FiberQueue#

This class acts as a collection or linear data structure that stores elements in FIFO (First In, First Out) order.

Public Functions

FiberQueue(std::size_t max_size)#
boost::fibers::channel_op_status put(
pybind11::object &&item,
bool block = true,
float timeout = 0.0
)#

Item to the queue. Await the acknowledgement delays based on the timeout that has been specified.

Parameters:

  • item –

  • block –

  • timeout –

Returns:

boost::fibers::channel_op_status

boost::fibers::channel_op_status get(
pybind11::object &item,
bool block = true,
float timeout = 0.0
)#

Retrieves item from head of the queue.

Parameters:

  • item –

  • block –

  • timeout –

Returns:

boost::fibers::channel_op_status

void close()#

TODO(Documentation)

bool is_closed()#

TODO(Documentation)

void join()#

TODO(Documentation)