gevent.threadpool

class ThreadPool(maxsize, hub=None)

Bases: gevent.pool.GroupMappingMixin

maxsize
size
join()

Waits until all outstanding tasks have been completed.

kill()
adjust()
spawn(func, *args, **kwargs)

Add a new task to the threadpool that will run func(*args, **kwargs).

Waits until a slot is available. Creates a new thread if necessary.

Returns:A gevent.event.AsyncResult.
apply_e(expected_errors, function, args=None, kwargs=None)

Deprecated since version 1.1a2: Identical to apply(); the expected_errors argument is ignored.

class ThreadResult(receiver, hub=None, call_when_ready=None)

Bases: object

exc_info = ()
exception
destroy()
set(value)
handle_error(context, exc_info)
successful()

Next page: gevent.util