Handy-Http/transport
Handy-Http
/
transport
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Define custom task pool instead of default phobos.
Build and Test Module / build-and-test (push) Successful in 12s Details
Build and Test Module / integration-tests (push) Successful in 18s Details

This commit is contained in:
Andrew Lalis 2025-08-09 11:20:02 -04:00
parent 5e79fba1b4
commit 01d48e9537
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/handy_http_transport/http1/task_pool.d
View File

@ -13,8 +13,11 @@ import slf4d;
* and submitted to the standard task pool. * and submitted to the standard task pool.
*/ */
class TaskPoolHttp1Transport : Http1Transport { class TaskPoolHttp1Transport : Http1Transport {
private TaskPool httpTaskPool;
this(HttpRequestHandler requestHandler, ushort port = 8080) { this(HttpRequestHandler requestHandler, ushort port = 8080) {
super(requestHandler, port); super(requestHandler, port);
this.httpTaskPool = new TaskPool(5);
} }
override void runServer() { override void runServer() {
@ -31,13 +34,14 @@ class TaskPoolHttp1Transport : Http1Transport {
Socket clientSocket = serverSocket.accept(); Socket clientSocket = serverSocket.accept();
trace("Accepted a new socket."); trace("Accepted a new socket.");
auto t = task!handleClient(clientSocket, requestHandler); auto t = task!handleClient(clientSocket, requestHandler);
taskPool().put(t); this.httpTaskPool.put(t);
trace("Added handleClient() task to the task pool."); trace("Added handleClient() task to the task pool.");
} catch (SocketAcceptException e) { } catch (SocketAcceptException e) {
warn("Failed to accept socket connection.", e); warn("Failed to accept socket connection.", e);
} }
} }
serverSocket.close(); serverSocket.close();
this.httpTaskPool.stop();
} }
override void stop() { override void stop() {