为什么python asyncio coroutine在Line socket.RECV(1024)处暂停?为什么Whi

Question

我有一个小应用程序，其中一个coroutine将发送数据，而另一个Coroutine将接收数据和日志，它是否收到了确切的发送数据。

两个旋律都在循环时。当trans（）coroutine和recv（）coroutine从xxxxxxx

击中线的产量时，trans（）coroutine and recv（）coroutine的某些方法没有进行。

data, server = yield from recv_sock.recvfrom(1024)

这是代码

import asyncio
import socket
import time
import datetime
import logging
trans_addr = ('localhost', 5555)
recv_addr = ('localhost',6666)
@asyncio.coroutine
def trans():
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    sock.bind(trans_addr)
    i = 0
    global sen_data
    while True:
        print("hi")
        sen_data = "HELLO " + str(i)
        sent = yield from sock.sendto(sen_data.encode(), recv_addr)
        print(sent)
        print("hi1")
        yield from time.sleep(2)
        i += 1
        print("hi1")
@asyncio.coroutine
def recv():
    recv_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    recv_sock.bind(recv_addr)  # binding the receiving end to 1.241 and port 6666
    #recv_sock.setblocking(0)
    while True:
        try:
            print("hello")
            data, server = yield from recv_sock.recvfrom(1024)
            print("hello2")
            if (data):
                recv_data = data.decode()
                if (sen_data == recv_data):
                    logging.info("transmitted data :" + sen_data + " is Received as :" + recv_data + " at :" + str(
                        datetime.datetime.now()) + 'n')
                    print("transmitted data :" + sen_data + " is Received as :" + recv_data + " at :" + str(
                        datetime.datetime.now()) + " from :" + str(server) + 'n')
                else:
                    logging.critical("Data missed : ")
                    logging.critical("Transmitted data " + sen_data + " is != " + "received data : " + recv_data + 'n')
                    print("data is missing--->")
                    print("Transmitted data " + sen_data + " is != " + "received data : " + recv_data + 'n')
        except:
            pass
            # print("not receiving data due to some fault in the receiving socket")
            # time.sleep(1)
loop=asyncio.get_event_loop()
tasks = [loop.create_task(trans()), loop.create_task(recv())]
wait_tasks = asyncio.wait(tasks)
loop.run_forever()
loop.run_until_complete(wait_tasks)

输出是：

hello
hi

谁能让我知道，为什么Coroutines无法从命令中跨越产量？我正在使用Python 3.3.2

Answer 1

yield from或await应与Coroutines一起使用。recvfrom不是Coroutine。例如，您可以使用loop.sock_recv()：

reader, writer = socket.socketpair()
writer.setblocking(False)
reader.setblocking(False)
await loop.sock_recv(...)
await loop.sock_sendall(...)