Re: spawninig of more than 8 threads problem

[IronHawk]

**@wiffel, @Araq:**

Thanks a lot! I really missed that it's impossible to use spawn with closures. 
:(

So the sample should look like below one. It's much more verbose, but it works 
properly.
    
    
    import unicode, locks, os
    
    proc lenU*(s: string): int =
      result = s.runeLen
    
    proc charAtPosU*(s: string, pos: int): string =
      assert(pos >= 0 and pos < s.runeLen)
      result = s.runeAtPos(pos).toUTF8()
    
    type
      Container = ref ContainerObj
      ContainerObj = object of RootObj
        Flk: Lock
        FnLen: int
        FnCallsTotal: int
        FnCallsCur: int
        FnCallIndex: int
      
      WorkerThread = Thread[tuple[cont: Container, c: string, value: int]]
    
    proc newContainer(nLen, nCount: int): Container =
      result.new()
      result.Flk.initLock()
      result.FnLen = nLen
      result.FnCallsTotal = nLen*nCount
      result.FnCallsCur = 0
      result.FnCallIndex = 0
    
    proc isTimeToFinish(self: Container): bool =
      result = self.FnCallsCur == self.FnCallsTotal
    
    proc isOurCallIndex(self: Container, nCallIndex: int): bool =
      result = self.FnCallIndex == nCallIndex
    
    proc goToNextCallIndex(self: Container) =
      inc self.FnCallIndex
      self.FnCallIndex = self.FnCallIndex mod self.FnLen
      inc self.FnCallsCur
    
    proc destroyContainer(cont: var Container) =
      cont.Flk.deinitLock()
      cont = nil
    
    proc worker(param: tuple[cont: Container, c: string, value: int]) 
{.thread.} =
      while true:
        var bWorkDone = true
        param.cont.Flk.acquire()
        try:
          if param.cont.isTimeToFinish:
            return
          if param.cont.isOurCallIndex(param.value):
            param.cont.goToNextCallIndex()
            stdout.write param.c
          else:
            bWorkDone = false
        finally:
          param.cont.Flk.release()
        if not bWorkDone:
          sleep(1)
    
    proc multithreadedPrint(sMsg: string, nCount: int) =
      var
        cont = newContainer(sMsg.len, nCount)
        threads: seq[WorkerThread] = newSeq[WorkerThread](sMsg.len)
      for i in 0..<sMsg.len:
        threads[i].createThread(worker, (cont, sMsg.charAtPosU(i), i))
      joinThreads(threads)
      destroyContainer(cont)
    
    multithreadedPrint("01234567890123456789", 3)
    echo ""