From 56867b7c12c6991bdbf77b93d702fd4574b5cf51 Mon Sep 17 00:00:00 2001
From: chang-ning <spiderpower02@gmail.com>
Date: Mon, 15 May 2023 10:14:33 -0700
Subject: [PATCH] add asyncio notes about thread

Signed-off-by: chang-ning <spiderpower02@gmail.com>
---
 docs/notes/python-asyncio.rst | 63 +++++++++++++++++++++++++++++++++++
 1 file changed, 63 insertions(+)

diff --git a/docs/notes/python-asyncio.rst b/docs/notes/python-asyncio.rst
index 879e5e22..0b63f35d 100644
--- a/docs/notes/python-asyncio.rst
+++ b/docs/notes/python-asyncio.rst
@@ -1286,3 +1286,66 @@ Simple asyncio WSGI web server
 
 
 .. _29679: https://bugs.python.org/issue29679
+
+
+Run in Executor
+---------------
+
+.. code-block:: python
+
+    import asyncio
+    import urllib.request
+
+    from concurrent.futures import ThreadPoolExecutor
+
+    def fetch(url):
+        with urllib.request.urlopen(url) as f:
+            return f.read(4096)
+
+
+    async def main():
+        loop = asyncio.get_event_loop()
+        url = "http://www.python.org/"
+        with ThreadPoolExecutor() as e:
+            res = await loop.run_in_executor(e, fetch, url)
+            print(res)
+
+    asyncio.run(main())
+
+
+Run in Thread
+-------------
+
+.. code-block:: python
+
+    import asyncio
+    import urllib.request
+
+    from threading import Thread
+
+    class AsyncThread(Thread):
+        def __init__(self, *a, **kw):
+            super().__init__(*a, **kw)
+            self.loop = asyncio.new_event_loop()
+
+        def dispatch(self, coro):
+            return asyncio.run_coroutine_threadsafe(coro, loop=self.loop).result()
+
+        def run(self):
+            self.loop.run_forever()
+
+        def stop(self):
+            self.loop.call_soon_threadsafe(self.loop.stop)
+            self.join()
+
+
+    async def fetch(url):
+        loop = asyncio.get_event_loop()
+        with urllib.request.urlopen(url) as f:
+            return await loop.run_in_executor(None, f.read, 4096)
+
+    t = AsyncThread()
+    t.start()
+    res = t.dispatch(fetch("http://www.python.org/"))
+    print(res)
+    t.stop()