JamThreadHelper

Inherits: Node < Object

A Node that provides utilities for simplifying common Thread operations

Properties

Mutex

_product_mtx

new()

Dictionary

_product_map

{}

Timer

_lazy_timer

Timer

_thread_wait_timer

Methods

JamThreadHelper.ThreadProduct

take_product ( int id )

void

put_product ( int id, JamThreadHelper.ThreadProduct product )

void

producer_wrapper ( int id, Callable producer )

JamThreadHelper.ProducerHandle

_add_a_producer ( Callable producer )

JamThreadHelper.ThreadProduct

run_threaded_producer ( Callable producer )

JamThreadHelper.ThreadProduct[]

run_multiple_producers ( Callable[] producers )


Property Descriptions

Mutex _product_mtx = new()

There is currently no description for this property. Please help us by contributing one!


Dictionary _product_map = {}

There is currently no description for this property. Please help us by contributing one!


Timer _lazy_timer

There is currently no description for this property. Please help us by contributing one!


Timer _thread_wait_timer

  • Timer @_thread_wait_timer_getter ( )

There is currently no description for this property. Please help us by contributing one!


Method Descriptions

JamThreadHelper.ThreadProduct take_product ( int id )

There is currently no description for this method. Please help us by contributing one!


void put_product ( int id, JamThreadHelper.ThreadProduct product )

There is currently no description for this method. Please help us by contributing one!


void producer_wrapper ( int id, Callable producer )

There is currently no description for this method. Please help us by contributing one!


JamThreadHelper.ProducerHandle _add_a_producer ( Callable producer )

There is currently no description for this method. Please help us by contributing one!


JamThreadHelper.ThreadProduct run_threaded_producer ( Callable producer )

An awaitable function that runs a thread-safe function on a separate thread and retrieves the return value. Useful for async-ifying functions and retrieving their result.


JamThreadHelper.ThreadProduct[] run_multiple_producers ( Callable[] producers )

There is currently no description for this method. Please help us by contributing one!