bucky.util.async_thread

Wrapper for an async thread operating on data in a queue.

Module Contents

Classes

AsyncQueueThread

Async thread that processes data put into its queue.

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)

Async thread that processes data put into its queue.

close(self)

Close thread and clean up.

put(self, x)

Add item to thread’s queue.

bucky.util.async_thread._thread_target(_queue, func, pre_func, post_func, **kwargs)

Wrapper around functionals that becomes the target for the thread.

previous

bucky.util

next

bucky.util.cached_prop