TaskPoolWorkerPool

A basic worker pool implementation that uses Phobos' std.parallelism and its TaskPool to asynchronously process requests. Due to the temporary nature of Phobos' tasks, a new receive buffer must be allocated for each request.

Constructors

this
this(size_t workerCount)

Constructs this worker pool for the given server.

Inherited Members

From RequestWorkerPool

start
void start()

Starts the pool, so that it will be able to process requests.

submit
void submit(HttpServer server, Socket socket)

Submits a client socket to this pool for processing.

stop
void stop()

Stops the pool, so that no more requests may be processed.