from multiprocessing import Process, Queue

from time import sleep

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()}")

        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()

        #p.join()

为什么要加join，不然会报错，mac

Traceback (most recent call last):

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

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

Traceback (most recent call last):

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

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

        exitcode = _main(fd, parent_sentinel)exitcode = _main(fd, parent_sentinel)

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

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

    self = reduction.pickle.load(from_parent)

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

self = reduction.pickle.load(from_parent)

  File "/Library/Frameworks/Python.framework/Versions/3.10/lib/python3.10/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.10/lib/python3.10/multiprocessing/spawn.py", line 116, in spawn_main

    exitcode = _main(fd, parent_sentinel)

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

    self = reduction.pickle.load(from_parent)

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

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

FileNotFoundError: [Errno 2] No such file or directory

请问协程不是在IO的时候会切换到另一任务吗，为什么缺点里却又会阻塞整个程序？ 老师 这样把这个问题解释详细一点吗 

老师，自建类MyThread继承了Thread类，但其中name属性应该是Thread类的初始化函数中的参数，子类继承父类但不继承初始化函数，但上述程序中自建类为什么能访问name属性呢？

老师，我感觉这个进程池中的apply 同步运行这个‘同步’我还是不太懂，我感觉在用apply给进程池中的进程分任务的时候要等待这个进程执行完才能分配下一个任务，像是线程中的串联运行，但是这个‘同步’是指什么同步？

然后在用apply_async 变成了异步运行，实际上就是每个进程不等其他进程执行的怎么样了，只要进程池里还有进程就执行任务，这个‘异步’又是什么‘异步’呢？

from threading import Thread
from queue import Queue
from time import sleep
def producter():
    num = 1
    while True:
        print(f'生产第{num}个手机')
        mq.put(f'消费了第{num}个手机')
        num+=1
        sleep(1)
def consumer():
    while True:
        m = mq.get()
        print(m)
        # sleep(1)
if __name__ == '__main__':
    mq=Queue()
    t1=Thread(target=producter)
    t2=Thread(target=consumer)
    t1.start()
    t2.start()

#ffsfs

a = 0
sum_a = 0

while a <=100 and a%2 ==1:
    sum_a += a
    a +=1
print("1-100所有奇数的累加和为：",sum_a)

老师请问一下，为什么我的软件安装不上?是安装路径有问题吗?

Running cells with 'Python 3.8.5 32-bit' requires ipykernel installed or requires an update.

老师，我的vscode 在交互模式运行的时候，总是跳出来这个，我该如何解决？

multiprocessing
time

write(q):
    value [,,]:
        (,value)
        q.put(value)
        time.sleep()

read(q):
    :
        q.empty():
            (,q.get())
            time.sleep()
        :
            __name__ == :
    q = multiprocessing.Queue()
    pw = multiprocessing.Process(= write,=(q,))
    pr = multiprocessing.Process(= read,=(q,))
    pw.start()
    pw.join()

    pr.start()
    pr.join()
    ()

复制的程序 执行结果不对

为什么照抄的报错了。。

from threading import Thread
  #线程的实现
  #方法包装
#创建普通的方法
def func1(name):
    print(f"Threading:{name} start")

#创建线程
t1 = Thread(target=func1,args=('t1'))
t2 = Thread(target=func1,args=('t2'))

#开启线程
t1.start()
t2.start()

错误代码是这个

Exception in thread Thread-1:

Traceback (most recent call last):

  File "C:\Program Files\Python38\lib\threading.py", line 932, in _bootstrap_inner

    self.run()

  File "C:\Program Files\Python38\lib\threading.py", line 870, in run

    self._target(*self._args, **self._kwargs)

TypeError: func1() takes 1 positional argument but 2 were given

Process finished with exit code 0

老师 对于协程是怎么工作的 还是有些不理解 例如这里有个单线程 它里边创建了3个协程  但是现在这里有5个任务  那这三个协程是怎么工作的   

老师，我检查过代码，和视频里是一样的，但是我的person不显示print运行，只有car的运行，这是为什么？

from time import sleep
from threading import Thread
from threading import Event

def car():
    # global count
    num = 0
    while True:
        if even.is_set():  # if count % 5 != 0:
            print("车已到站，可以上车")
            sleep(1)
            num += 1  # count += 1
            if num % 5 == 0:
                even.clear()
        else:
            print("车开走了，请等待")
            sleep(6)
            # count = 1
            even.set()

def person():
    while True:
        if even.is_set():  # if count % 5 != 0:
            print("上车！")
            sleep(1)
        else:
            print("等待车！！！")
            even.wait()
            # sleep(1)

if __name__ == "__main__":
    even = Event()  # count = 1
    t1 = Thread(target = car)
    t2 = Thread(target = person)
    t1.start()
    t2.start()

老师，你说queue中的消息是无序的，那我第一次取出来的消息我再put进去你怎么保证我二次执行for循环的时候取出来的不是同样的消息呢？

# 服务器端：一个线程专门发送消息，一个线程专门接收消息。
# 客户端：一个线程专门发送消息，一个线程专门接收消息。
# 结合多线程实现TCP双向传送(自由聊天)
# 【示例】TCP服务端结合多线程实现自由收发信息



from socket import *
from threading import Thread
def recv_data():
    while True:
        # 读取客户端的消息
        re_data = tcp_client_socket.recv(1024)
        re_content =re_data.decode('gbk')
        # 将消息输出到控制台
        print(f"客户端说:{re_content},from:{host}")
        if re_content == '88':
            break
        # 获取控制台信息
def send_data():
    while True:
        msg = input(">")
        tcp_client_socket.send(msg.encode("gbk"))

if __name__ == '__main__':
    tcp_server_socket = socket(AF_INET, SOCK_STREAM)
    tcp_server_socket.bind(('127.0.0.1', 8888))
    tcp_server_socket.listen()
    print("服务端已经启动，等待客户端连接！")
    tcp_client_socket, host = tcp_server_socket.accept()
    print("一个客户端建立连接成功！")

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


tcp_client_socket.close()
tcp_server_socket.close()

from socket import *
from threading import Thread

def recv_data():
    while True:
        redata=tcp_client_socket.recv(1024)
        recv_data=redata.decode('gbk')
        print(f"服务器端说:{recv_data}")
def send_data():
    while True:
        msg=input(">")
        tcp_client_socket.send(msg.encode("gbk"))
        if msg == '88':
            break
if __name__ == '__main__':

    tcp_client_socket=socket(AF_INET,SOCK_STREAM)
    tcp_client_socket.connect(('127.0.0.1',8888))
    print("连接建立成功")
    t1=Thread(target=recv_data())
    t2=Thread(target=send_data())
    t1.start()
    t2.start()
    t1.join()
    t2.join()
tcp_client_socket.close()

这个持续通信中的发送消息接收信息判断为什么不生效，当输入88的时候

老师，当多个线程进入可运行状态后，能否像多个进程那行多个线程同时运行，还是像上述 PPT里讲的那样，只能一个一个线程单独运行？