请问老师，要怎么修改呢，一直报错，说类型不符合

import asyncio
import functools


async def compute(x, y):
    print(f'compute:{x}+{y}...')
    await asyncio.sleep(1)
    return x+y


async def print_sum(x, y):        # python3.5以上
    # 创建task
    task = asyncio.create_task(compute(x, y))
    # task绑定回调函数
    task.add_done_callback(functools.partial(end, x, y))
    # 释放下cpu的使用
    await asyncio.sleep(1)


def end(n, m, t):
    print(f'{n}+{m}={t.result()}')


if __name__ == '__main__':
    # 创建事件循环
    loop = asyncio.get_event_loop()
    # 监听事件循环
    loop.run_until_complete(print_sum(1, 2))
    # 关闭事件循环
    loop.close()

老师，这边我还是不懂执行的过程，有几个问题问一下      1、这边开始运行之后先是执行print_sum函数，然后到了print_sum函数中的await时释放cpu去执行compute（）函数，然后到了compute（）函数中的await时又会回到print_sum函数中是吗？是这样的话那print_sum中的tast = asyncio.create_tast(compute())和tast.add_done_callback(functools.partial(end,x,y)不是已经运行过了吗，从compute（）函数返回时是再执行一边print_sum函数的内容吗？     2、这里end函数中的t为什么就是tast

老师，请问一下这个两个f分别是什么意思呢？我有点不太确定

第二个f是不是代表方法中的num用i+1来代？

还有画红线的地方不懂诶。意思我能理解，不过写法有点懵,  ("{ }",)，外面小括号是元组，里面中括号是什么意思？

1 def func1():
2     for i in range(11):
3         print(f'北京打印第{i}次数据')
4         yield
5 
6 
7 def func2():
8     g = func1()
9     next(g)
10    for i in range(10):
11        print(f'上海打印第{i}次数据')
12        next(g)
13
14
15if __name__ == '__main__':
16    func2()

老师，第一次运行时这里的第12行next（g）中的g是‘第0次’还是‘第1次’

老师，这里的pool.join（）中的join是什么意思？

struct
socket *
filename = server_ip = send_data = struct.pack(% (filename), , filename.encode(), , .encode(), )
s = socket(AF_INET, SOCK_DGRAM)
s.sendto(send_data, (server_ip, ))  f = (filename, )  :
    recv_data = s.recvfrom()  caozuoma, ack_num = struct.unpack(, recv_data[][:])  rand_port = recv_data[][]  (caozuoma) == :
        ()
        (%(caozuoma, ack_num, rand_port, (recv_data[])))
    f.write(recv_data[][:])(recv_data[]) < :
        ack_data = struct.pack(, , ack_num)
    s.sendto(ack_data, (server_ip, rand_port))

老师麻烦解答一下，谢谢！

代码如下：

struct
socket *
filename = server_ip = send_data = struct.pack(% (filename), , filename.encode(), , .encode(), )
s = socket(AF_INET, SOCK_DGRAM)
s.sendto(send_data, (server_ip, ))  f = (filename, )  :
    recv_data = s.recvfrom()  caozuoma, ack_num = struct.unpack(, recv_data[][:])  rand_port = recv_data[][]  (caozuoma) == :
        ()
        (%(caozuoma, ack_num, rand_port, (recv_data[])))
    f.write(recv_data[][:])(recv_data[]) < :
        ack_data = struct.pack(, , ack_num)
    s.sendto(ack_data, (server_ip, rand_port))

老师好，怎么我的代码执行结果是文件不存在呢？我的图片是按照相对路径来复制粘贴的呀！

代码如下：

struct
socket *
filename = server_ip = send_data = struct.pack(% (filename), , filename.encode(), , .encode(), )
s = socket(AF_INET, SOCK_DGRAM)
s.sendto(send_data, (server_ip, ))  f = (filename, )  :
    recv_data = s.recvfrom()  caozuoma, ack_num = struct.unpack(, recv_data[][:])  rand_port = recv_data[][]  (caozuoma) == :
        ()
        (%(caozuoma, ack_num, rand_port, (recv_data[])))
    f.write(recv_data[][:])(recv_data[]) < :
        ack_data = struct.pack(, , ack_num)
    s.sendto(ack_data, (server_ip, rand_port))

老师您好

from socket import *
import asyncio
# 给对方传递信息
s = socket(AF_INET, SOCK_DGRAM)  # ipv4协议 使用的是udp协议
s.bind(("", 5431))
addr = ("172.27.150.26", 8080)  # ip 地址和端口地址
async def fun1():
    while True:
        date = input("请输入要选择的内容")
        s.sendto(date.encode("gb2312"), addr)       # 将字符流转为字符串

async def fun2():
    while True:
        task = asyncio.create_task(fun1())
        task.add_done_callback()
        redate = s.recvfrom(10)
        print(redate[0].decode("gb2312"))
if __name__ == '__main__':
    f1 = fun1()
    f2 = fun2()
    loop = asyncio.get_event_loop()
    loop.run_until_complete(f2)
    loop.close()

我想用进程的方法实现它可以同时接受信息，请问要怎么做才行啊？

老师，下面的callback回调函数的作用是什么？写与不写的区别在哪里？好像不影响进程的效率

p.apply_async(func=func1, args=(f"p{i+1}", ), callback=func2)

老师这个回调函数有具体介绍吗？不清楚。。

from time import sleep
from threading import Thread
from threading import BoundedSemaphore


def an_jian(num):
    lock.acquire()
    print(f'第{num}个人完成安检！')
    sleep(2)
    lock.release()


if __name__ == '__main__':
    lock = BoundedSemaphore(3)
    for i in range(10):
        t = Thread(target=an_jian, args=(f'{i+1}',))
        t.start()

老师，这里调用an_jian方法后面的括号为什么不需要，还有什么时候调用需要加括号什么时候不需要加

#coding=UTF-8

from threading import Thread, Event
from time import sleep
from random import randint


def door():
    global state
    while True:
        if even.is_set():#如果even事件为真，则执行
            print('我是门：门开着，可以通行~')
            sleep(1)
        else:
            print('我是门：门关了~请刷卡！')
            state = 0#门已关闭，开门循环重置为0
            even.wait()#even事件为等待，进程暂停
        if state > 3:#state在3次循环后
            print('我是门：超过3 秒，门自动关门')
            even.clear() #even事件为假，所有even.wait()发挥作用，将进程暂停
        state +=1#循环一次，state+1，控制门开启时间
        sleep(1)#线程暂停1秒，控制循环时间
def person():
    global state
    n = 0#人员编号
    while True:
        if even.is_set():
            print('我是人：门开着：{}号进入'.format(n))
        else:
            even.set()#将even事件标记为真
            state = 0#开门循环重置为0
            print('我是人：门关着，{}号人刷卡进门'.format(n))
        n += 1
        sleep(randint(1, 10))#随机1-10米秒来一个人，模拟刷卡
if __name__ == '__main__':
    state = 0
    even = Event()
    even.set()
    d = Thread(target=door)
    d.start()
    p = Thread(target=person)
    p.start()

老师，在执行的时候应该先提示

我是门：门关了~请刷卡！

但是我的这个程序，直接就是开着门的，请帮忙看看问题在哪里，谢谢

老师从哪里可以看最多可以一次进行多少个线程啊？如果系统一共能开8个线程我开了4个，他们和开一个的效率一样吗？

老师从哪里可以看最多可以一次进行多少个线程啊？如果系统一共能开8个线程我开了4个，他们和开一个的效率一样吗？