Go 语言中的 Python 异步事件循环等价物

Question

我使用asyncio事件循环，这是一种在Python3.x中执行异步/并发任务。

在线程上是否有任何相当于asyncio (async/await) 或 Go 语言中的协程？

---

[注意]：

不是parallelism + concurrency（多处理）模式。

---

[更新]：

这是一个在 Python 中使用 asyncio 的异步事件循环，以便更好地理解：

import asyncio
import time

async def async_say(delay, msg):
    await asyncio.sleep(delay)
    print(msg)

async def main():
    task1 = asyncio.ensure_future(async_say(4, 'hello'))
    task2 = asyncio.ensure_future(async_say(6, 'world'))

    print(f"started at {time.strftime('%X')}")
    await task1
    await task2
    print(f"finished at {time.strftime('%X')}")

loop = asyncio.get_event_loop()
loop.run_until_complete(main())

输出：

started at 13:19:44
hello
world
finished at 13:19:50

---

任何帮助将不胜感激。

Answer 1

在 Python 术语中，事件循环内置于 Go。您可以使用 go async_say(...) 启动两个 goroutine 并等待它们完成，例如使用 channel 或 wait group。

您的代码到 Go 的直接翻译可能如下所示：

package main

import "fmt"
import "time"

func async_say(delay time.Duration, msg string, done chan bool) {
    time.Sleep(delay)
    fmt.Println(msg)
    done <- true
}

func main() {
    done1 := make(chan bool, 1)
    go async_say(4 * time.Second, "hello", done1)
    done2 := make(chan bool, 1)
    go async_say(6 * time.Second, "world", done2)
    <-done1
    <-done2
}

请注意，与 Python（和 JavaScript 等）不同，Go 函数的 colors 不会因它们是否异步而不同。它们可以全部异步运行，标准库中内置了等效的 asyncio。

Answer 2

在 Go 中你不需要这个，因为在 Go 中这将是一种反模式。

相反，在 Go 中，您可以管理 "pollable" descriptors（例如套接字）与运行时和 goroutine 调度程序紧密集成。 这允许您编写普通的 sequential 代码，这些代码将在内部通过特定于平台的“事件”接口（例如 Linux 上的 epoll、FreeBSD 上的 kqueue 和 Windows 上的 IOCP）进行处理。 一旦 goroutine 尝试在套接字上执行任何 I/O 并且套接字尚未准备好，goroutine 就会暂停，直到该数据准备好之后，它将在暂停的地方恢复。

因此，在 Go 中，您只需创建一个单独的 goroutine 来处理应该与其他请求同时执行或服务的每个请求，并编写简单的顺序代码来处理它。

对于背景，开始here 和here。

解释 Go 调度程序如何工作的教程是， 例如，this 和this。