mirror of
https://github.com/logos-storage/apatheia.git
synced 2026-01-04 05:53:11 +00:00
cleanup
This commit is contained in:
parent
f1b953db81
commit
ba17d8090e
@ -24,9 +24,6 @@ proc addNums(jobResult: JobResult[float], a, b: float) =
|
|||||||
|
|
||||||
suite "async tests":
|
suite "async tests":
|
||||||
|
|
||||||
# var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
|
|
||||||
# var queue = newSignalQueue[float]()
|
|
||||||
|
|
||||||
var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
|
var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
|
||||||
|
|
||||||
asyncTest "test":
|
asyncTest "test":
|
||||||
|
|||||||
@ -7,12 +7,8 @@ import taskpools
|
|||||||
|
|
||||||
import apatheia/queues
|
import apatheia/queues
|
||||||
|
|
||||||
## todo: setup basic async + threadsignal + taskpools example here
|
|
||||||
##
|
|
||||||
|
|
||||||
proc addNums(a, b: float, queue: SignalQueue[float]) =
|
proc addNums(a, b: float, queue: SignalQueue[float]) =
|
||||||
os.sleep(500)
|
os.sleep(50)
|
||||||
echo "adding: ", a, " + ", b
|
|
||||||
discard queue.send(a + b)
|
discard queue.send(a + b)
|
||||||
|
|
||||||
suite "async tests":
|
suite "async tests":
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user