diff options
| author | Araq <rumpf_a@web.de> | 2014-09-22 01:25:13 +0200 |
|---|---|---|
| committer | Araq <rumpf_a@web.de> | 2014-09-22 01:25:13 +0200 |
| commit | 1a3b730bf5a2e5978d2dad3d8fb4c157134535e7 (patch) | |
| tree | 7a7b23ba1232224ee57a91e3550b3ee4f0a8c551 /lib/pure | |
| parent | ed3c5094845d5674279c1fd8bdf4da27a0eed561 (diff) | |
| download | Nim-1a3b730bf5a2e5978d2dad3d8fb4c157134535e7.tar.gz | |
made tests green
Diffstat (limited to 'lib/pure')
| -rw-r--r-- | lib/pure/concurrency/threadpool.nim | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/pure/concurrency/threadpool.nim b/lib/pure/concurrency/threadpool.nim index fe08e94fc..7b0593b3e 100644 --- a/lib/pure/concurrency/threadpool.nim +++ b/lib/pure/concurrency/threadpool.nim @@ -94,7 +94,7 @@ type idx: int FlowVarBase* = ref FlowVarBaseObj ## untyped base class for 'FlowVar[T]' - FlowVarBaseObj = object of TObject + FlowVarBaseObj = object of RootObj ready, usesCondVar: bool cv: CondVar #\ # for 'awaitAny' support @@ -164,7 +164,7 @@ proc cleanFlowVars(w: ptr Worker) = let q = addr(w.q) acquire(q.lock) for i in 0 .. <q.len: - GC_unref(cast[PObject](q.data[i])) + GC_unref(cast[RootRef](q.data[i])) q.len = 0 release(q.lock) signal(q.empty) |