mirror of
https://github.com/Open-Argon/http.ar.git
synced 2026-10-28 09:43:55 +00:00
minimise the number of threads being created to be a fixed number
This commit is contained in:
1 parent
c84a8455d3
commit
f52fa27656
3 files changed
+5
-4
No files matched your search
+1
-1
@@ -1,4 +1,4 @@
|
||||
{
|
||||
"name": "http.ar",
|
||||
"version": "1.1.3"
|
||||
"version": "1.1.4"
|
||||
}
|
||||
+3
-2
@@ -14,7 +14,7 @@ let setDebug(value) = do
|
||||
term.log("Debug mode disabled")
|
||||
|
||||
let server() = do
|
||||
let class = {port: 3000, numThreads: 5, callback: ()=term.log("Server running on port "+class.port)}
|
||||
let class = {port: 3000, numThreads: 10, callback: ()=term.log("Server running on port "+class.port)}
|
||||
let threads = []
|
||||
let routes = []
|
||||
let Socket = null
|
||||
@@ -27,7 +27,8 @@ let server() = do
|
||||
throwError("Server already running")
|
||||
Socket = socket.server("tcp", class.port)
|
||||
let starter() = do
|
||||
thread(()=listener.listener(Socket, routes, class.onErr)).start()
|
||||
for (i from 0 to class.numThreads) do
|
||||
thread(()=listener.listener(Socket, routes, class.onErr)).start()
|
||||
class.callback()
|
||||
let t = thread(starter)
|
||||
t.start()
|
||||
|
||||
+1
-1
@@ -3,5 +3,5 @@ import "handleRequest" as handleRequest
|
||||
let listener(Socket, routes, onErr) = do
|
||||
while (not Socket.isClosed()) try do
|
||||
let accept = Socket.accept()
|
||||
thread(()=handleRequest.handle(routes, accept, onErr)).start()
|
||||
handleRequest.handle(routes, accept, onErr)
|
||||
catch (e) if (onErr) onErr(e)
|
||||
Reference in new issue
Block a user