2.10 – Coroutines

Lua supports coroutines, also called semi-coroutines or collaborative multithreading. A coroutine in Lua represents an independent thread of execution. Unlike threads in multithread systems, however, a coroutine only suspends its execution by explicitly calling a yield function.

You create a coroutine with a call to coroutine.create. Its sole argument is a function that is the main function of the coroutine. The create function only creates a new coroutine and returns a handle to it (an object of type thread); it does not start the coroutine execution.

When you first call coroutine.resume, passing as its first argument the thread returned by coroutine.create, the coroutine starts its execution, at the first line of its main function. Extra arguments passed to coroutine.resume are given as parameters for the coroutine main function. After the coroutine starts running, it runs until it terminates or yields.

A coroutine can terminate its execution in two ways: Normally, when its main function returns (explicitly or implicitly, after the last instruction); and abnormally, if there is an unprotected error. In the first case, coroutine.resume returns true, plus any values returned by the coroutine main function. In case of errors, coroutine.resume returns false plus an error message.

A coroutine yields by calling coroutine.yield. When a coroutine yields, the corresponding coroutine.resume returns immediately, even if the yield happens inside nested function calls (that is, not in the main function, but in a function directly or indirectly called by the main function). In the case of a yield, coroutine.resume also returns true, plus any values passed to coroutine.yield. The next time you resume the same coroutine, it continues its execution from the point where it yielded, with the call to coroutine.yield returning any extra arguments passed to coroutine.resume.

The coroutine.wrap function creates a coroutine like coroutine.create, but instead of returning the coroutine itself, it returns a function that, when called, resumes the coroutine. Any arguments passed to that function go as extra arguments to resume. The function returns all the values returned by resume, except the first one (the boolean error code). Unlike coroutine.resume, this function does not catch errors; any error is propagated to the caller.

As an example, consider the next code:

  1. function foo1 (a)
  2. print("foo", a)
  3. return coroutine.yield(2*a)
  4. end
  5.  
  6. co = coroutine.create(function (a,b)
  7. print("co-body", a, b)
  8. local r = foo1(a+1)
  9. print("co-body", r)
  10. local r, s = coroutine.yield(a+b, a-b)
  11. print("co-body", r, s)
  12. return b, "end"
  13. end)
  14.  
  15. a, b = coroutine.resume(co, 1, 10)
  16. print("main", a, b)
  17. a, b, c = coroutine.resume(co, "r")
  18. print("main", a, b, c)
  19. a, b, c = coroutine.resume(co, "x", "y")
  20. print("main", a, b, c)
  21. a, b = coroutine.resume(co, "x", "y")
  22. print("main", a, b)

When you run it, it produces the following output:

  1. co-body 1 10
  2. foo 2
  3. main true 4
  4. co-body r
  5. main true 11 -9
  6. co-body x y
  7. main true 10 end
  8. main false cannot resume dead coroutine