Wrapper for an async thread operating on data in a queue.
Module Contents
Functions
_thread_target(_queue, func, pre_func, post_func, **kwargs)
|
Wrapper around functionals that becomes the target for the thread. |
-
class bucky.util.async_thread.AsyncQueueThread(func, pre_func=None, post_func=None, queue_maxsize=100, **kwargs)[source]
Async thread that processes data put into its queue.
-
close(self)[source]
Close thread and clean up.
-
put(self, x)[source]
Add item to thread’s queue.
-
bucky.util.async_thread._thread_target(_queue, func, pre_func, post_func, **kwargs)[source]
Wrapper around functionals that becomes the target for the thread.