嘶，为什么会一直的报错啊，打开顺序没错的。

发送方

接收方

怎么运行他们两通不了信？打开接收方再打开发送方，输入内容就不动了

recv_data = s.recvfrom(1024)

显示这行代码报错,说是

[WinError 10022] 提供了一个无效的参数。

'''
目的：首先生产完十个加菲猫，然后让t2,t3去抢，抢到完1个之后，producer补充，依次无限循环执行
问题：当生产完十个之后，再继续执行sleep(10),没有进行t2,t3的抢购行为
'''

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

def producer():
    num = 1
    while not mq.full():
        print(f"生产了{num}号加菲猫")
        mq.put(f"{num}")
        num += 1
        sleep(1)
        print(mq.full())
    sleep(10) #为防止程序马上结束使函数延长十秒，以方便consumer()能被执行，但实际上consumer没有被执行
            
def consumer():
    while mq.full():
        print("购买了{}号加菲猫".format(mq.get()))
        sleep(1)

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

老师请问car方法里边else最后不是换成True了吗？程序自上而下执行，那么在person里边不是该执行if后边的语句了吗？

from threading import Thread
from threading import Event


def car():
    num = 0
    while True:
        if event.is_set():
            print('车到站！上车')
            sleep(1)  # 上一个人加一秒
            num += 1
            if num % 5 == 0:
                event.clear()
        else:
            print('车已经开走')
            sleep(6)
            event.set()
def person():
    while True:
        if event.is_set():
            print('车来了，上车')
            sleep(1)
        else:
            print('等待车!!!')
            event.wait()

if __name__ == '__main__':
    event=Event()
    t1=Thread(target=car)
    t2=Thread(target=person)
    t1.start()
    t2.start()

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