Nimでマルチスレッドで起動してスレッド間で変数を共有する

jester1.nim

import asyncdispatch, json

import jester

var
  v = "sushi"

router myrouter:
  get "/":
    {.gcsafe.}:
      v.add("1")
    resp %*{"status":"ok"}

proc main =
  var settings = newSettings(port = Port(5000))
  var jester = initJester(myrouter, settings = settings)
  jester.serve()

when isMainModule:
  main()

multithreads.nim

import os, threadpool

var
  sharedVar = 1
  v = "str"

proc heavyMethod1(): int =
    echo "1: Start"
    sleep(5000)
    echo "1: End"
    inc(sharedVar)
    {.gcsafe.}:
      v.add("test1")
    return 5

proc heavyMethod2(): int =
    echo "2: Start"
    sleep(2000)
    echo "2: End"
    {.gcsafe.}:
      v.add("test2")
    return 20

var result1 = spawn heavyMethod1()
var result2 = spawn heavyMethod2()
sync()

echo ^result1
echo ^result2
echo sharedVar
echo v

multithreads2.nim

# クラッシュしたコード
import os, threadpool

var
  v = "str"

proc heavyMethod1(): int =
  for i in 1..1000:
    {.gcsafe.}:
      v.add("1")
      echo "thread 1: " & v
  return 5

proc heavyMethod2(): int =
  for i in 1..1000:
    {.gcsafe.}:
      v.add("2")
      echo "thread 2: " & v
  return 20

var result1 = spawn heavyMethod1()
var result2 = spawn heavyMethod2()
sync()

echo ^result1
echo ^result2
echo v

multithreads3.nim

import os, threadpool

var
  v = "str"

proc heavyMethod1(): int =
  for i in 1..1000:
    {.gcsafe.}:
      v.add("1")
  return 5

proc heavyMethod2(): int =
  for i in 1..1000:
    {.gcsafe.}:
      v.add("2")
  return 20

var result1 = spawn heavyMethod1()
var result2 = spawn heavyMethod2()
sync()

echo ^result1
echo ^result2
echo v

multithreads4.nim

import os, threadpool

var
  v = "str"

proc heavyMethod1(n: int): int =
  for i in 1..1000:
    {.gcsafe.}:
      v.add($n)
  return 5

for i in 1..100:
  var result1 = spawn heavyMethod1(i)
sync()

echo v

threads.nim

import locks

var
  thr: array[0..4, Thread[tuple[a,b: int]]]
  L: Lock

proc threadFunc(interval: tuple[a,b: int]) {.thread.} =
  for i in interval.a..interval.b:
    acquire(L) # lock stdout
    echo i
    release(L)

initLock(L)

for i in 0..high(thr):
  createThread(thr[i], threadFunc, (i*10, i*10+5))
joinThreads(thr)

multithreads2.nim のほうだとクラッシュした

{.gcsafe.} プラグマ内でechoしたのが不味いっぽい。
echoするのを消したらクラッシュしなくなった。
標準出力に書き込むことの副作用の関係だろうか。

multithreads3.nim ならクラッシュしなかった

jester1.nimに対して以下のリクエストを送りつけたらクラッシュした。
内容としては、curlをバックグラウンドで1000回なげた。
echoしてなくてもクラッシュする場合があるっぽい。

for i in {1..1000}; do curl http://localhost:5000 & done

multithreads4.nim はクラッシュした。引数からは値をわたせないのだろうか

multithreads4.nim、 nim c --threads:on --gc:boehm で実行したらクラッシュしなかった。

jester1.nim を同じ方法で実行したら処理の途中でOOMで死んだ。boehmって何なんだろう

https://nim-lang.org/docs/threads.html にかかれていた threads モジュールのサンプルは動いた