fix invalid join (#25896)

can't join a thread that wasn't started (causes random crashes)

(cherry picked from commit 7fa006c4e5)
This commit is contained in:
Jacek Sieka
2026-06-11 20:24:48 +02:00
committed by narimiran
parent c536a32856
commit 706c317903

View File

@@ -14,12 +14,6 @@ type WorkProc[A, B] = proc(a: A): Option[B] {.nimcall.}
proc worker[TArg](p: TArg) {.thread, nimcall.} =
discard
proc readFilesThread() =
type TArg[A, B] =
tuple[r: ptr Channel[Option[A]], w: ptr Channel[Option[B]], p: WorkProc[A, B]]
var readThread: Thread[TArg[int, SharedBuf]]
proc readFilesAd() {.async.} =
var readChan: Channel[Option[int]]
@@ -29,8 +23,6 @@ proc readFilesAd() {.async.} =
var readThread: Thread[TArg[int, SharedBuf]]
let test = await (addr readChan).recv()
joinThread(readThread)
waitFor readFilesAd()
type