add tests for new ds'es

This commit is contained in:
Jaremy Creechley 2023-08-30 18:24:12 -07:00 committed by Dmitriy Ryajov
parent 0caa606f3e
commit 619d3e9d56
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
2 changed files with 3 additions and 35 deletions

View File

@ -1,34 +0,0 @@
import
std/[strutils, math, cpuinfo],
taskpools
# From https://github.com/nim-lang/Nim/blob/v1.6.2/tests/parallel/tpi.nim
# Leibniz Formula https://en.wikipedia.org/wiki/Leibniz_formula_for_%CF%80
proc term(k: int): float =
if k mod 2 == 1:
-4'f / float(2*k + 1)
else:
4'f / float(2*k + 1)
proc piApprox(tp: Taskpool, n: int): float =
var pendingFuts = newSeq[FlowVar[float]](n)
for k in 0 ..< pendingFuts.len:
pendingFuts[k] = tp.spawn term(k) # Schedule a task on the threadpool a return a handle to retrieve the result.
for k in 0 ..< pendingFuts.len:
result += sync pendingFuts[k] # Block until the result is available.
proc main() =
var n = 1_000_000
var nthreads = countProcessors()
var tp = Taskpool.new(num_threads = nthreads) # Default to the number of hardware threads.
echo formatFloat(tp.piApprox(n))
tp.syncAll() # Block until all pending tasks are processed (implied in tp.shutdown())
tp.shutdown()
# Compile with nim c -r -d:release --threads:on --outdir:build example.nim
main()

View File

@ -4,6 +4,8 @@ import
./datastore/testfsds,
./datastore/testsql,
./datastore/testtieredds,
./datastore/testmountedds
./datastore/testmountedds,
./datastore/testmemoryds,
./datastore/testthreadproxyds
{.warning[UnusedImport]: off.}