jyapayne/Nim
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fixes #13781; fixes #14901; add acyclic pragmas to FlowVar (#20804)

Browse source 
* add acyclic pragmas to FlowVar

* add testcases
This commit is contained in:
ringabout 2022-11-10 16:54:39 +08:00 • committed by GitHub
commit 2848cdb18a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 12 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
lib/pure/concurrency/threadpool.nim
View file

@ -102,7 +102,7 @@ type
idx: int idx: int
FlowVarBase* = ref FlowVarBaseObj ## Untyped base class for `FlowVar[T] <#FlowVar>`_. FlowVarBase* = ref FlowVarBaseObj ## Untyped base class for `FlowVar[T] <#FlowVar>`_.
FlowVarBaseObj = object of RootObj FlowVarBaseObj {.acyclic.} = object of RootObj
ready, usesSemaphore, awaited: bool ready, usesSemaphore, awaited: bool
cv: Semaphore # for 'blockUntilAny' support cv: Semaphore # for 'blockUntilAny' support
ai: ptr AwaitInfo ai: ptr AwaitInfo
@ -111,7 +111,7 @@ type
# be RootRef here otherwise the wrong GC keeps track of it! # be RootRef here otherwise the wrong GC keeps track of it!
owner: pointer # ptr Worker owner: pointer # ptr Worker
FlowVarObj[T] = object of FlowVarBaseObj FlowVarObj[T] {.acyclic.} = object of FlowVarBaseObj
blob: T blob: T
FlowVar*[T] {.compilerproc.} = ref FlowVarObj[T] ## A data flow variable. FlowVar*[T] {.compilerproc.} = ref FlowVarObj[T] ## A data flow variable.

11
tests/parallel/tlet_spawn.nim
View file

@ -4,7 +4,7 @@ done999 999
''' '''
""" """
import threadpool import std/[threadpool, os]
proc foo(): int = 999 proc foo(): int = 999
@ -17,3 +17,12 @@ proc main =
echo "done", f, " ", b echo "done", f, " ", b
main() main()
# bug #13781
proc thread(): string =
os.sleep(1000)
return "ok"
var fv = spawn thread()
sync()
doAssert ^fv == "ok"