JanetDocs SourcePlayground I'm feeling lucky CommunityGitHub sign in

ev/thread

core-api



    cfunction
    src/core/ev.c on line 3104, column 1

    (ev/thread main &opt value flags supervisor)

    Run `main` in a new operating system thread, optionally passing 
    `value` to resume with. The parameter `main` can either be a fiber, 
    or a function that accepts 0 or 1 arguments. Unlike `ev/go`, this 
    function will suspend the current fiber until the thread is 
    complete. If you want to run the thread without waiting for a 
    result, pass the `:n` flag to return nil immediately. Otherwise, 
    returns nil. Available flags:

     $*$  `:n`  $-$  return immediately
     $*$  `:t`  $-$  set the task-id of the new thread to value. The task-id is 
      passed in messages to the supervisor channel.
     $*$  `:a`  $-$  don't copy abstract registry to new thread (performance 
      optimization)
     $*$  `:c`  $-$  don't copy cfunction registry to new thread (performance 
      optimization)

1 exampleSign in to add an example

# channels that can be used for communication between os threads
(def chan-a (ev/thread-chan 10))
(def chan-b (ev/thread-chan 10))

# one thread
(ev/thread
  (fiber/new
    (fn []
      (def msg "hi")
      (print "thread 1 sending: " msg)
      (ev/give chan-a msg)
      #
      (print "thread 1 received: " (ev/take chan-b))))
  :1
  :n)

# another thread
(ev/thread
  (fiber/new
    (fn []
      (print "thread 2 received: " (ev/take chan-a))
      #
      (def msg "peace")
      (print "thread 2 sending: " msg)
      (ev/give chan-b msg)))
  :2
  :n)

# expected output
#
# thread 1 sending: hi
# thread 2 received: hi
# thread 2 sending: peace
# thread 1 received: peace

sogaiuPlayground