example1.nim

# =======
# Imports
# =======


import json
import strformat
import asyncdispatch

import threadproxy

# =====
# Types
# =====

type
  Queue = object
    name: string
    token: ThreadToken
    thread: Thread[QueueTask]

  QueueTask = object
    token: ThreadToken

  QueueManager = object
    main: MainThreadProxy

  QueueMain = proc (task: QueueTask) {.thread, nimcall.}

# =========
# Functions
# =========

# =======
# Threads
# =======

proc workerMain(task: QueueTask) {.thread.} =
  let proxy = newThreadProxy(task.token)

  # register action handler
  proxy.onData "multiply":
    echo "processing task!"
    let x = data["value"].getInt()
    return %*{"value": x + 20}

  # start processing channel
  waitFor proxy.poll()

proc response(f: Future[JsonNode]) =
  echo "future callback!"
  let data = f.read()
  let value = data["value"].getInt()
  echo fmt"{value - 20} -> {value}"

# ===========
# Entry Point
# ===========

proc main() =
  let proxy = newMainThreadProxy("main")
  asyncCheck proxy.poll()

  proxy.onData "stop":
    proxy.stop()

  let token = proxy.createToken("thread_1")
  var worker: Thread[QueueTask]
  createThread(worker, workerMain, QueueTask(token: token))

  let index = 8
  # for index in 0..10:
  let data = %*{"value": index}
  echo "dispatching task: " & $data
  let answer = proxy.ask("thread_1", "multiply", data)
  answer.addCallback response

  echo "done dispatching"
  runForever()

when isMainModule:
  main()