老师这个怎么解决？

#coding=utf-8
from socket import*
from threading import Thread


def recv_data():
    while True:
        recv_data =s.recvfrom(1024)  # 1024表示本次接受的最大节数
        recv_content = recv_data[0].decode("gbk")
        print(f'收到远程信息：{recv_content},from{recv_data[1]}')
        if recv_content == "88":
            print("聊天结束")
            break


def send_data():
    addr = (('127.0.0.1', 8888))
    while True:
        data = input("请输入：")
        # 发送数据时，python3需要将字符串转成byte
        s.sendto(data.encode('gbk'), addr)  # 默认的网络助手使用的编码是gbk
        if data == "88":
            print("聊天结束")
            break




if __name__=="__main__":
    s = socket(AF_INET, SOCK_DGRAM)  # 创建套接字
    addr = (('127.0.0.1', 8989))  # 准备接受地址
    t1=Thread(target=recv_data)
    t2=Thread(target=send_data)
    t1.start()
    t2.start()
    t1.join()
    t2.join()

from multiprocessing import Process, Queue
from time import sleep
#encoding=utf-8


class MyProcess(Process):
    def __init__(self, name, mq):
        Process.__init__(self)
        self.name = name
        self.mq = mq

    def run(self):
        print(f'Process:{self.name},start')
        print(f'get Data:{self.mq.get()}')
        self.mq.put(self.name)
        sleep(3)
        print(f'Process:{self.name},end')


if __name__ == '__main__':
    mq = Queue()
    mq.put('1')
    mq.put('2')
    mq.put('3')
    p_list = []
    for i in range(3):
        p = MyProcess(f'p{i}',mq)
        p_list.append(p)
    for p in p_list:
        p.start()

C:\Users\kjin\PycharmProjects\pythonProject\venv\Scripts\python.exe C:\Users\kjin\PycharmProjects\pythonProject\queue.py 

Traceback (most recent call last):

  File "C:\Users\kjin\PycharmProjects\pythonProject\queue.py", line 21, in <module>

    mq = Queue()

         ^^^^^^^

  File "C:\Users\kjin\AppData\Local\Programs\Python\Python311\Lib\multiprocessing\context.py", line 102, in Queue

    from .queues import Queue

  File "C:\Users\kjin\AppData\Local\Programs\Python\Python311\Lib\multiprocessing\queues.py", line 21, in <module>

    from queue import Empty, Full

ImportError: cannot import name 'Empty' from 'queue' (C:\Users\kjin\PycharmProjects\pythonProject\queue.py)

Process finished with exit code 1

为什么这两处都报错了？？？

sleep（）这个我大概明白怎么改，但是为什么name这里不对？

跟着视频里打的，怎么报错了啊

为什么我的程序从上到下运行到了print("主线程，end"),主线程结束了,守护线程t1还在运行。

九:

还有这个，我设置一个守护线程t1，普通线程t2，运行结果里面，他们并没有抢先=线运行

这个地方为什么没有换行

老师，这里面没有用到父类的属性，为什么还需要初始化父类方法

这个为什么用targe和targs？

老师，这个怎么解决啊

#未使用线程同步和互斥锁的情况
from threading import Thread
from time import sleep

class Account:
    def __init__(self,money,name):
        self.name=name
        self.money=money

#模拟提款的操作
class Drawing(Thread):
    def __init__(self,drawingNum,account):
        Thread.__init__(self)
        self.drawingNum=drawingNum
        self.account=account
        self.expenseTotal=0   #一共取了多少
    def run(self):
        if self.account.money< self.drawingNum:
            return 
        sleep(1)   #判断完可以取钱，堵塞。就是为了测试发生冲突问题
        self.account.money -= self.drawingNum
        self.expenseTotal += self.drawingNum
        print(f"账户:{self.account.name},余额是：{self.account.money}")
        print(f"账户：{self.account.name},总共取了：{self.account.expenseTotal}")

if __name__=="__main__":
    a1=Account(100,"v")
    draw1=Drawing(80,"v")   #  定义一个取钱的线程
    draw2=Drawing(80,"v")   #在定义一个取钱的线程
    draw1.start()
    draw2.start()

z这个是什么原因？

#coding=utf-8
from threading import Thread
from time import sleep

def func1(name):
    print(f"线程{name},start")  # f 就是format
    for i in range(3):
        print(f"线程：{name},{i}:")
        sleep(1)
    print(f"线程{name},end")

if __name__=='__main__':
    print("主线程，start")
    #创建线程
    t1 = Thread(target=func1,args=("t1",))
    t2 = Thread(target=func1,args=("t2",))
    #启动线程
    t1.start()
    t2.start()
    print("主线程,end")

主线程，start

线程t1,start

线程：t1,0:

线程t2,start

线程：t2,0:

主线程,end

线程：t1,1:

线程：t2,1:

线程：t1,2:

线程：t2,2:

线程t1,end

线程t2,end

老师，有点不太明白这个代码运行的步骤 能帮我解释一下吗

from queue import Queue
from threading import Thread
from time import sleep

def producter():
    num = 1
    while True:
        if queue.qsize()<5:
            print(f"生产{num}号，手机")
            queue.put(f"手机：{num}号，")
            num+=1
        else:
            print("库存满了，请消费")
        sleep(1)


def consumer():
    while True:
        print(f"获取手机：{queue.get()}")
        sleep(1)

if __name__ == '__main__':
    queue=Queue()
    p = Thread(target=producter())
    p.start()
    c = Thread(target=consumer())
    c.start()
    c2 = Thread(target=consumer())
    c2.start()

消费线程没有启动，好奇怪

#coding=utf-8
from socket import *
from threading import Thread

def recv_data():
    while True:
        recv_data = client_socket.recv(1024).decode('gbk')
        print(f"客户端信息{recv_data}")

def send_data():
    while True:
        input_info = input("服务器发送消息：")
        input_info = client_socket.send(input_info.encode("gbk"))
        if input_info == "end":
            break

if __name__ == '__main__':
    chatroom_socket = socket(AF_INET,SOCK_STREAM)
    chatroom_socket.bind(("127.0.0.1",8850))
    chatroom_socket.listen()
    client_socket,socket_info=chatroom_socket.accept()
    print('服务器等待客户端连接')
    t1 = Thread(target=recv_data)
    t2 = Thread(target=send_data)
    t1.start()
    t2.start()
    t1.join()
    t2.join()
    client_socket.close()
    chatroom_socket.close()
    
    
#coding=utf-8
from socket import *
from threading import Thread

def recv_data():
    while True:
        recv_data = client_socket.recv(1024).decode('gbk')
        print(f"服务器信息：{recv_data}")

def send_data():
    while True:
        msg = input("客户端发送消息：")
        msg = client_socket.send(msg.encode("gbk"))
        if msg == "end":
            break

if __name__ == '__main__':
    client_socket = socket(AF_INET,SOCK_STREAM)
    client_socket.connect(("127.0.0.1",8850))
    print("客户端器连接服务器")
    t1 = Thread(target=recv_data)
    t2 = Thread(target=send_data)
    t1.start()
    t2.start()
    t1.join()
    t2.join()
    client_socket.close()

输入end无法结束