Querier

Querier.

@safe final

class Querier {

struct MutexedAA(AA : V[K], V, K) via import lu.container : MutexedAA;;

Tid[] workers;

size_t nextWorkerIndex;

MutexedAA!(HTTPQueryResponse[int]) responseBucket;

this(uint numWorkers);

auto nextWorker();

void teardown();

static void listenInThread(MutexedAA!(HTTPQueryResponse[int]) responseBucket, uint id);

}

Constructors

this this(uint numWorkers): Constructor.

Members

Functions

nextWorker auto nextWorker(): Yields the Tid of the next worker in line.
teardown void teardown(): Effectively a destructor. Stops all workers.

Static functions

listenInThread void listenInThread(MutexedAA!(HTTPQueryResponse[int]) responseBucket, uint id): Listens for concurrency messages to issue HTTP requests.

Variables

nextWorkerIndex size_t nextWorkerIndex;: Index of the next worker to use.
responseBucket MutexedAA!(HTTPQueryResponse[int]) responseBucket;: Responses to HTTP queries.
workers Tid[] workers;: Tid array of worker threads.