Nim/tests/parallel/tsendtwice.nim

discard """
  matrix: "--mm:refc"
"""

# bug #4776

import tables, algorithm

type
  Base* = ref object of RootObj
    someSeq: seq[int]
    baseData: array[40000, byte]
  Derived* = ref object of Base
    data: array[40000, byte]

type
  ThreadPool = ref object
    threads: seq[ptr Thread[ThreadArg]]
    channels: seq[ThreadArg]
  TableChannel = Channel[TableRef[string, Base]]
  ThreadArg = ptr TableChannel

var globalTable {.threadvar.}: TableRef[string, Base]
globalTable = newTable[string, Base]()
let d = new(Derived)
globalTable.add("ob", d)
globalTable.add("ob2", d)
globalTable.add("ob3", d)

proc `<`(x, y: seq[int]): bool = x.len < y.len
proc kvs(t: TableRef[string, Base]): seq[(string, seq[int])] =
  for k, v in t.pairs: result.add (k, v.someSeq)
  result.sort

proc testThread(channel: ptr TableChannel) {.thread.} =
  globalTable = channel[].recv()
  var myObj: Base
  deepCopy(myObj, globalTable["ob"])
  myObj.someSeq = newSeq[int](100)
  let table = channel[].recv() # same table
  assert(table.contains("ob")) # fails!
  assert(table.contains("ob2")) # fails!
  assert(table.contains("ob3")) # fails!
  assert table.kvs == globalTable.kvs # Last to see above spot checks first

var channel: TableChannel

proc newThreadPool(threadCount: int) = #: ThreadPool =
  #new(result)
  #result.threads = newSeq[ptr Thread[ThreadArg]](threadCount)
  #var channel = cast[ptr TableChannel](allocShared0(sizeof(TableChannel)))
  channel.open()
  channel.send(globalTable)
  channel.send(globalTable)
  #createThread(threadPtr[], testThread, addr channel)
  testThread(addr channel)
  #result.threads[i] = threadPtr

proc stop(p: ThreadPool) =
  for t in p.threads:
    joinThread(t[])
    dealloc(t)


newThreadPool(1)#.stop()