(host, port, msg)
| 459 | import socket |
| 460 | |
| 461 | async def socket_task(host, port, msg): |
| 462 | s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
| 463 | s.connect((host, port)) |
| 464 | s.sendall(msg.encode()) |
| 465 | data = s.recv(1024) |
| 466 | s.close() |
| 467 | return data.decode() |
| 468 | |
| 469 | r1, r2 = await asyncio.gather( |
| 470 | socket_task(host1, port1, "msg1"), socket_task(host2, port2, "msg2") |