# 协程实现生产者和消费者

def consumer():
    while True:
        n = yield
        print(f"生产了第{n}个产品")
def producter():
    g = consumer()
    # print(next(g))
    # next(g)
    for i in range(5):
        g.send(i)
        print(f"消费了第{i}产品")
        # func1()
if __name__ == "__main__":
   producter()

老师您好，这段代码为什么没有next（g）的时候会报错，或者说next（g）在这里的作用是什么？

那个软件怎么汉化，把那个Chinese.ptl复制到那个目录下面。之前的人问过，我没看懂。

图片在资源管理器中，但是图像打不开，请老师解释一下。

与百度的解决方法与我的错误不对应，不能解决。

from socket import *
import struct

filename = input("请输入需要下载的文件名：")
server_ip = "192.168.1.102"
send_data = struct.pack("!H%dsb5sb" % len(filename), 1, filename.encode(), 0, "octet".encode(), 0)  #pack封装成字节流
s = socket(AF_INET, SOCK_DGRAM)
s.sendto(send_data, (server_ip, 69))    #发送请求
f = open(filename, "ab")
while True:
    recv_data = s.recvfrom(1024)    #接收数据
    caozuoma, ack_num = struct.unpack("!HH", recv_data[0][:4])  #unpack解析字节流
    rand_port = recv_data[1][1] #获取服务器的随机端口
    if int(caozuoma) == 5:  #ERROR操作码是5
        print("文件不存在！")
        break
    print("操作码：{0}，ack：{1}，服务器随机端口：{2}，数据长度：{3}".format(caozuoma, ack_num, rand_port, len(recv_data[0])))
    f.write(recv_data[0][4:])   #写入数据
    if len(recv_data[0]) < 516:
        print("下载完毕")
        break
    ack_data = struct.pack("!HH", 4, ack_num)
    s.sendto(ack_data, (server_ip, rand_port))  #回复ACK确认包

你好，老师，请问一下为什么我的图片名为中文的时候就下载不成功，而文件名为英文的时候就能成功下载。

from threading import Thread,Lock
from time import sleep

def func1():  # 炒西兰花
    lock1.acquire()
    print('func1拿到菜刀--切菜')
    sleep(2)
    lock2.acquire()
    print('func1拿到锅--热锅')
    lock2.release()
    print('func1释放锅--完成')
    lock1.release()
    print('func1释放菜刀--完成')

def func2(): # 炒红烧肉
    lock2.acquire()
    print('func2拿到锅--热锅')
    lock1.acquire()
    print('func2拿到菜刀--切菜')
    lock1.release()
    print('func2释放菜刀--完成')
    lock2.release()
    print('func2释放锅--完成')

    if __name__ == "__main__":
        lock1 = Lock()  # 菜刀
        lock2 = Lock()  # 锅
        t1 = Thread(target = func1)
        t2 = Thread(target = func2)
        t1.start()
        t2.start()

老师 代码我都照着敲的 这个报错是我的python环境变量有问题吗

from threading import Thread,Lock
from time import sleep

def func1():  # 炒西兰花
    print("func1拿到菜刀--切菜")
    sleep(2)
    print("func1拿到锅--热锅")
    print("func1释放锅--完成")
    print("func1释放菜刀--完成")

def func2(): # 炒红烧肉
    print("func2拿到锅--热锅")
    print("func2拿到菜刀--切菜")
    print("func2释放菜刀--完成")
    print("func2释放锅--完成")

    if __name__ == "__main__":
        t1 = Thread(target = func1)
        t2 = Thread(target = func2)
        t1.start()
        t2.start()

老师 代码一样 但是打印不出来内容

from threading import Thread
from time import sleep

# 类实现-多线程
class MyThread(Thread):
    def __init__(self,name):
        Thread.__init__(self)
        self.name = name

    def run(self):
        print(f"Threading:{self.name} start")
        sleep(3)
        print(f"Threading:{self.name} end")
if __name__ == "__main__":
    
    # 创建线程
    for i in range(20):
        t = MyThread(f"t{i+1}")
        # 设置当前进程为 守护线程（必须在start前） 守护线程概念；当前主进程结束后，剩下子进程也结束，不造成资源浪费
        t.setDaemon(True)
        t.start()

print("主进程结束了！！！")
# 整个代码运行起来就是主线程 由主线程创建的thread对象 for循环就是子线程

老师 我线程搞明白了 但是进程没太弄明白 就是主进程和子进程

 f.write(recv_date[0][4:])  #将数据写入

这个地方如果客户端发送的ack服务器没有收到，服务器重新发送了一份数据，文件就出现问题了吧

from threading import Thread
from time import sleep,time
import threading
# Thread:线  
# 线程的实现
# 方法包装

# 创建普通方法
def func1(name):
    print(threading.currentThread())
    print(f"Threading:{name} start")  # f:输出一下哪个线程启动了,print语句一般都是提示信息,
    sleep(3)                           #不加也可以只是不会输出在控制台上(这里指的是name)
    print(f"Threading:{name} end")

if __name__ == "__main__":

    print(threading.currentThread())   # 打印默认的主线程 <_MainThread(MainThread, started 1068)>
    # 开始时间
    start = time()   # 时间测试
    '''
    # 创建线程
    t1 = Thread(target=func1,args=('t1',))  # t1后面加, 必须是元组     # 创建的是子线程
    t2 = Thread(target=func1,args=("t2",))
    # 开始时间
    start = time()
    # 开始线程
    t1.start()
    t2.start()
    # 等待t1线程执行完再往下执行
    t1.join()
    # 等待t2线程执行完再往下执行
    t2.join()
    #func1("t1")
    #func1("t2")
    '''
    thread_list = []
    for i in range(10):
        t = Thread(target=func1,args=(f"t{i+1}",))
        t.start()
        thread_list.append(t)
    for t in thread_list:
        t.join()    # join的使用 不要启动线程后立即join(),容易造成串行运行，导致并发失效
    # 结束时间
    end = time()-start
    print(end)

老师 这里多任务的实现是用了多线程模式方法吗 这里循环10个进程是子线程 主线程只有一个 就是MainThread吗

from socket import *
s=socket(AF_INET,SOCK_DGRAM)
s.bind(("",8788))
s.sendto("nihao".encode("gb2312"),("192.168.1.3",8080))
redata=s.recvfrom(1024)
print(redata[0].decode("gb2312"))
s.close()


from socket import *
udpSocket=sonket(AF_INET,SOCK_DGRAM)
udpSocket.bind(("",8080))
while True:
    recvData=udpSocket.recvfrom(1024)
    print(recvData[0].decode())
    data=("请输入:")
    udpSocket.sendto(data.ecode(),receData[1])
udpSocket.close()

以上是29和30的代码，为啥我在29运行的时候没有输出值啊

from socket import *
s=socket(AF_INET,SOCK_DGRAM)
addr=("196.168.1.3",8080)
data=input("请输入要发送的内容:")
s.sendto(data.encode("gb2312"),addr)

为啥我的代码运行完以后，网络调试端口一点反应都没有

from threading import Thread
from queue import Queue
from time import sleep
def producer():
    num = 1
    while True:
        
        print(f"生产{num}号加菲猫")
        mq.put(f"{num}号加菲猫")
        num+=1
        sleep(1)



def consumer():
    print(f"购买了{mq.get()}")
    sleep(2)
    
if __name__ == "__main__":
    mq = Queue(maxsize=10)
    t1 = Thread(target=producer)
    t2 = Thread(target=consumer)
    t3 = Thread(target=consumer)
    t1.start()
    t2.start()
    t3.start()

为什么代码运行完以后只有前两次是正常的，后面都是只生产不消费了

from threading import Thread,Event
from time import sleep
from random import randint
def door():
    while True:
        global state
        if even.is_set():
            print("门开着可以进门")
            sleep(1)
        else:
            state=0
            print("门关着请刷卡")
            even.wait()
        sleep(1)
        state+=1
        if state > 3:
            print("超过3秒,请刷卡")
            even.clear()
def person():
    num=1
    while True:
        global state
        
        if even.is_set():
            print(f"门开着,{num}号人进入")
        else: 
            print(f"门关着,{num}号人刷卡进入")
            even.set()
            # state=0
        num += 1
        sleep(randint(1,10))



if __name__ == "__main__":
    even=Event()
    state=0
    t1=Thread(target=door)
    t2=Thread(target=person)
    t1.start()
    t2.start()