bittensor.core.threadpool

Implements ThreadPoolExecutor.

Attributes

NULL_ENTRY
__author__
_shutdown
_threads_queues
logger

Exceptions

BrokenThreadPool

Classes

PriorityThreadPoolExecutor	Base threadpool executor with a priority queue.
_WorkItem

Functions

_worker(executor_reference, work_queue, initializer, ...)

Module Contents

exception bittensor.core.threadpool.BrokenThreadPool

Bases: concurrent.futures._base.BrokenExecutor

Raised when a worker thread in a ThreadPoolExecutor failed initializing.

Initialize self. See help(type(self)) for accurate signature.

bittensor.core.threadpool.NULL_ENTRY

class bittensor.core.threadpool.PriorityThreadPoolExecutor(maxsize=-1, max_workers=None, thread_name_prefix='', initializer=None, initargs=())

Bases: concurrent.futures._base.Executor

Base threadpool executor with a priority queue.

Initializes a new ThreadPoolExecutor instance.

Parameters:

• max_workers – The maximum number of threads that can be used to execute the given calls.

• thread_name_prefix – An optional name prefix to give our threads.

• initializer – An callable used to initialize worker threads.

• initargs – A tuple of arguments to pass to the initializer.

_adjust_thread_count()

_broken = False

_counter

_idle_semaphore

_initargs

_initializer

_initializer_failed()

_max_workers

_shutdown = False

_shutdown_lock

_thread_name_prefix

_threads

_work_queue

classmethod add_args(parser, prefix=None)

Accept specific arguments from parser

Parameters:

• parser (argparse.ArgumentParser)

• prefix (str)

classmethod config()

Get config from the argument parser.

Return: bittensor.Config() object.

Return type:

bittensor.core.config.Config

property is_empty

shutdown(wait=True)

Clean-up the resources associated with the Executor.

It is safe to call this method several times. Otherwise, no other methods can be called after this one.

Parameters:

• wait – If True then shutdown will not return until all running futures have finished executing and the resources used by the executor have been reclaimed.

• cancel_futures – If True then shutdown will cancel all pending futures. Futures that are completed or running will not be cancelled.

submit(fn, *args, **kwargs)

Submits a callable to be executed with the given arguments.

Schedules the callable to be executed as fn(*args, **kwargs) and returns a Future instance representing the execution of the callable.

Returns:

A Future representing the given call.

Parameters:

fn (Callable)

Return type:

concurrent.futures._base.Future

class bittensor.core.threadpool._WorkItem(future, fn, start_time, args, kwargs)

Bases: object

args

fn

future

kwargs

run()

Run the given work item

start_time

bittensor.core.threadpool.__author__ = 'Brian Quinlan (brian@sweetapp.com)'

bittensor.core.threadpool._shutdown = False

bittensor.core.threadpool._threads_queues

bittensor.core.threadpool._worker(executor_reference, work_queue, initializer, initargs)

bittensor.core.threadpool.logger