代码如下:

multiprocessing ProcessQueue
time sleep


MyProcess(Process):
    (namemq):
        Process.()
        .name = name
        .mq = mq

    ():
        (.name)
        (.mq.get())
        sleep()
        (.name)


__name__ == :
    mq = Queue()
    mq.put()
    mq.put()
    mq.put()
    p_list=[]
    i ():
        p = MyProcess(imq)
        p_list.append(p)

    p p_list:
        p.start()

在mac下会报错 没有join的情况，为什么报如下的错误:

Traceback (most recent call last):

  File "<string>", line 1, in <module>

  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main

Traceback (most recent call last):

      File "<string>", line 1, in <module>

exitcode = _main(fd, parent_sentinel)

  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 126, in _main

  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main

    self = reduction.pickle.load(from_parent)

  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/synchronize.py", line 110, in __setstate__

    exitcode = _main(fd, parent_sentinel)

  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 126, in _main

    self = reduction.pickle.load(from_parent)

  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/synchronize.py", line 110, in __setstate__

    self._semlock = _multiprocessing.SemLock._rebuild(*state)

FileNotFoundError: [Errno 2] No such file or directory

    self._semlock = _multiprocessing.SemLock._rebuild(*state)

FileNotFoundError: [Errno 2] No such file or directory

Traceback (most recent call last):

  File "<string>", line 1, in <module>

  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main

    exitcode = _main(fd, parent_sentinel)

  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 126, in _main

    self = reduction.pickle.load(from_parent)

  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/synchronize.py", line 110, in __setstate__

    self._semlock = _multiprocessing.SemLock._rebuild(*state)

FileNotFoundError: [Errno 2] No such file or directory

threading Thread
time sleep


MyThread(Thread):
    (name):
        Thread.()
        .name = name

    ():
        i ():
            (.namei)
            sleep()


__name__ == :
    ()
    t1 = MyThread()
      t2 = MyThread()
    t1.start()
      t2.start()

t1 = MyThread()
t2 = MyThread()

这块不用传递参数吗，给参数t1就报错

具体服务器编程在哪个章节的哪个部分

老师，为什么queue队列没有传入生产函数和消费函数中也能被函数修改？

from queue import Queue
from threading import Thread, Lock, Semaphore
from time import sleep


def producer():
    print("开始生产")
    n=1
    while True:
        if queue.qsize() < 5:
            queue.put(f"生产{n}号")
            print(f"生产{n}号")
            n+=1
        else:
            print("已满")
            sleep(5)
def cons():
    print("开始消费")
    while True:
        if queue.qsize() >= 0:
            print(f"获取{queue.get()}")
            sleep(1)

if __name__ == '__main__':
    queue = Queue()
    a = Thread(target=producer)
    b = Thread(target=cons)
    a.start()
    b.start()

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


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

# 模拟提款操作
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(2)  # 判断完可以取钱，则阻塞。就是为了测试发生冲突问题
        self.account.money -= self.drawingNum
        self.expenseTotal += self.drawingNum
        print(f"账户：{self.account.name},余额是:{self.account.money}")
        print(f"账户：{self.account.name},总共取了:{self.expenseTotal}")

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

老师，这里Account中的2个属性是如何能被Drawing类所使用，没有调用也没有继承，是如何传递过去的？

老师语法结构不熟悉，有没有好的方法建议一下

老师，下边这个是错在哪里了？红色和黄色报警都没了，还是错。

from socket import *
from threading import Thread

def recv_data():
    while True:
        recv_data = client_socket.recv(1024)  # 最大接收1024字
        print(f"客户端说:{recv_data.decode('gbk')},来自：{client_info}")
        if recv_data == "end":
            break

def send_data():
    while True:
        msg = input(">")
        client_socket.send(msg.encode("gbk"))


if __name__ =='__main__':
    server_socket = socket(AF_INET, SOCK_STREAM)  # 建立TCP套接字
    server_socket.bind(("127.0.0.1", 8899))  # 本机监听8899端口
    server_socket.listen(5)
    print("等待接收连接！")
    client_socket, client_info = server_socket.accept()
    print("一个客户端建立连接成功！")

    t1 = Thread(target=recv_data)
    t2 = Thread(target=send_data)
    t1.start()
    t2.start()
    t1.join()
    t2.join()

    client_socket.close()
    server_socket.close()

在TCP编程3服务端和客户端持续通信这一节视频的5分15秒，按照老师打的recv_data显示错误，有以下报错。能帮看下吗？

老师下边这个UPD报错是什么原因呢？

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", 9999)
    while True:
        data = input("请输入： ")
        s.sendto(data.encode("gbk"), addr)
        if data == "88":
            print("聊天结束！")
            break

if __name__ == '__main__':
    s = socket(AF_INET, SOCK_DGRAM)  # 创建UDP类型的套接字
    s.bind(("127.0.0.1", 8888))  # 绑定端口，ip可以不写
    #创建两个线程
    t1 = Thread(target=recv_data)
    t2 = Thread(target=recv_data)
    t1.start()
    t2.start()
    t1.join()
    t2.join()

#服务端
#coding=utf-8
from socket import *
#最简化的UDP服务端代码
s = socket(AF_INET,SOCK_DGRAM)  #创建UDP类型的套接字
s.bind(("127.0.0.1",8888))  #绑定端口,ip可以不写
print("等待接收数据！")
recv_data = s.recvfrom(1024)    #1024表示本次接收的最大字节数
print(f"收到远程信息:{recv_data[0].decode('gbk')},from {recv_data[1]}")
s.close()

#客户端
#coding=utf-8
from socket import *
#最简化的UDP客户端发送消息代码
s = socket(AF_INET,SOCK_DGRAM)  #创建UDP类型的套接字
addr = ("127.0.0.1",8888)
data = input("请输入：")
s.sendto(data.encode("gbk"),addr)
s.close()

没明白服务端和客户端这两个编码为什么要这样写：看下面

decode('gbk')和data.encode("gbk")

如下图，如果上边没有import的话；__name__== '__main__'这种形式就会引用其里边包含的内容，但是既然有了上边的import，为什么__name__== '__main__'里边的内容还在被用？

老师，之前说python里边一切皆对象，那下边红色部分的se=Semaphore是等号左边的变量se是“信号量对象”，还是右边的`Semaphore是“信号量对象”呢？

time
asyncio

():
    i ():
        (i)
        asyncio.sleep()
    ():
    i ():
        (i)
        asyncio.sleep()
    ():
    res = asyncio.gather(func1(), func2())
    (res)
__name__ == :
    start_time = time.time()
    asyncio.run(main())
    end_time = time.time()
    (end_time-start_time)

老师,你看我这段代码,,为什么报错

threading Thread
time sleep


MyThread(Thread):
    (name):
        Thread.()
        .name=name

    ():
        (.name)
        i ():
            (.namei)
            sleep()
        (.name)
__name__ == :
    ()
    t1=MyThread()
    t1.daemon=t1.start()
    ()

为什么设置为了守护线程 他在主程序结束后 还在运行