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