python-asyncio

0熱度

1回答

如何在Python3中與asyncio共享套接字？

我需要使用asyncio和os.fork()方法來在子進程之間共享套接字。 data_received()回調函數中有heavy_jobs()函數，這將佔用大量的CPU時間。 import asyncio class EchoClientProtocol(asyncio.Protocol): def __init__(self, message, loop): self.

python python-3.x sockets python-asyncio 2017-08-19

---

1熱度

1回答

一個asyncio程序來管理許多其他

最近我一直在試驗discord bots，它使用asyncio。我一直在製作一個程序，控制很多其他的機器人，在飛行中打開和關閉它們，但我有一個問題;我已經嘗試過使用subprocess.Popen，rpyc和multiprocessing，但我正在努力研究如何在程序之間進行通信。我用下面的代碼行啓動子流程的嘗試： Popen('python smallprogram.py', stdout=PIP

python asynchronous subprocess python-asyncio discord 2017-08-20

---

1熱度

1回答

調用協程並在asyncio.Protocol.data_received（）中獲得未來？

我需要ASYNCIO循環內的未來結果，它類似於Calling a coroutine from asyncio.Protocol.data_received 但是在PY35和PY34 asyncio是完全不同的，這裏有可能在PY34正確運行的代碼，但在PY35將在暫停yield from並永不返回。 # PY34 class RelayClient(asyncio.Protocol):

python-3.x python-asyncio 2017-08-21

---

25熱度

2回答

從流中產生的正確方法是什麼？

我有用於包含讀和寫的asyncio連接流的Connection對象： class Connection(object): def __init__(self, stream_in, stream_out): object.__init__(self) self.__in = stream_in self.__out = stream_out

python python-3.x generator python-asyncio yield-from 2017-08-26

---

3熱度

1回答

使用ASYNCIO與封閉代碼

首先，我看了看this，this和this和而第一有一些有用的信息，因爲我試圖遍歷值不是與此有關。 這是我希望能夠做的事情的例子： class BlockingIter: def __iter__(self): while True: yield input() async def coroutine(): my_iter = BlockingIt

python iterator python-asyncio 2017-08-27

---

5熱度

1回答

如何以非阻塞的方式鏈接期貨？也就是說，如何在不阻塞的情況下將未來用作未來的輸入？

使用下面的示例，一旦future1完成（不阻止future3被提交），future2如何使用future1的結果？ from concurrent.futures import ProcessPoolExecutor import time def wait(seconds): time.sleep(seconds) return seconds pool = Pro

python python-3.x multiprocessing python-asyncio concurrent.futures 2017-08-28

---

3熱度

1回答

在PyCharm中調試異步代碼導致絕對瘋狂的不可重複的錯誤

在我的基於asyncio和asyncio tcp連接來調試PyCharm調試器的項目中，我得到了非常非常非常荒謬的錯誤。 如果我在運行後在代碼上放置斷點，斷點永遠不會觸發。 但是，如果在啓動程序之前放置了斷點，斷點將會觸發。 但在某些情況下，斷點觸發會導致奇怪的錯誤（如果在斷點處暫停並恢復）。 下一個例外我說： 類型錯誤： '協程' 對象不可調用的 關於SystemError：未知的操作碼 第一個

python debugging pycharm breakpoints python-asyncio 2017-08-29

---

1熱度

1回答

如何運行從Python程序很多aiohttp服務器

如何從1個Python程序運行許多aiohttp服務器 例子： manager = Manager() server1 = manager.create_server(config1) server2 = manager.create_server(config2) server1.run() # here program stop server2.run() # but i want t

python multithreading python-3.x python-asyncio aiohttp 2017-08-29

---

11熱度

2回答

Python aiohttp/asyncio - 如何處理返回的數據

在使用aiohttp將某些同步代碼移動到asyncio的過程中。同步代碼需要15分鐘才能運行，所以我希望能夠改善這一點。 我有一些工作代碼，它從一些網址獲取數據並返回每個網址的正文。但這只是針對1個實驗室網站，我有70多個實際網站。 因此，如果我有一個循環來創建所有網站的列表，所有的網站將使700個網址在列表中進行處理。現在處理它們我不認爲是一個問題？ 但是做結果的'東西'，我不知道如何編程？我的

python python-asyncio aiohttp 2017-08-30

---

1熱度

1回答

如何返回協程或字典（某些對象）？

我必須使用完全相同的邏輯方法。唯一的區別是它返回不同的值。 async def job_pooling(self): message['status'] = Text.NEW.value await self.db.store_alert(..) await self.aws.delete_message(..) yield message async

python python-3.x python-asyncio 2017-09-01

---