Async/Await ด้วยโคโรทีน

แนวคิดอะซิงก์/รอผล

ฟังก์ชันรอผล

local function await(future)
  local co = coroutine.running()
  future.onComplete = function(result)
    coroutine.resume(co, result)
  end
  return coroutine.yield()
end

ตัวห่อหุ้มฟังก์ชันอะซิงก์

local function async(fn)
  return function(...)
    local co = coroutine.create(fn)
    local ok, err = coroutine.resume(co, ...)
    if not ok then print("async error:", err) end
    return co
  end
end

ออบเจ็กต์ฟิวเจอร์อย่างง่าย

local function newFuture()
  local f = {done=false, value=nil, waiters={}}
  f.complete = function(val)
    f.done = true; f.value = val
    for _, cb in ipairs(f.waiters) do cb(val) end
  end
  f.andThen = function(cb)
    if f.done then cb(f.value)
    else f.waiters[#f.waiters+1] = cb end
  end
  return f
end

การใช้ await ในทางปฏิบัติ

local fetchData = async(function(url)
  local result = await(httpGet(url))  -- yields
  local parsed = await(parseJSON(result))  -- yields again
  print("Got:", parsed.name)
end)
fetchData("http://example.com/api")

การส่งต่อข้อผิดพลาด

local function awaitSafe(future)
  local co = coroutine.running()
  future.onComplete = function(ok, result)
    coroutine.resume(co, ok, result)
  end
  return coroutine.yield()
end

ทำงานตามลำดับเทียบกับทำงานขนาน

รูปแบบ Promise.all

local function all(futures)
  local results = {}
  local count = #futures
  local combined = newFuture()
  for i, f in ipairs(futures) do
    f:andThen(function(v)
      results[i] = v
      count = count - 1
      if count == 0 then combined.complete(results) end
    end)
  end
  return combined
end

การยกเลิก

การผสานรวมกับอินพุต/เอาต์พุต

เปรียบเทียบกับรูปแบบฟังก์ชันเรียกกลับ

คำถามเรื่องอะซิงก์/รอผล

ทบทวน: อะซิงก์/รอผลด้วยโครูทีน