queue = Queue()

老师，这条代码是什么意思啊

多线程确定了调度顺寻和单线线程的执行在没有遇到休眠或者I/O操作的情况下它们的执行速度是不是一样的？

老师麻烦解答一下，谢谢！

代码如下：

struct
socket *
filename = server_ip = send_data = struct.pack(% (filename), , filename.encode(), , .encode(), )
s = socket(AF_INET, SOCK_DGRAM)
s.sendto(send_data, (server_ip, ))  f = (filename, )  :
    recv_data = s.recvfrom()  caozuoma, ack_num = struct.unpack(, recv_data[][:])  rand_port = recv_data[][]  (caozuoma) == :
        ()
        (%(caozuoma, ack_num, rand_port, (recv_data[])))
    f.write(recv_data[][:])(recv_data[]) < :
        ack_data = struct.pack(, , ack_num)
    s.sendto(ack_data, (server_ip, rand_port))

#conding="utf-8"
from multiprocessing.context import Process
from multiprocessing.queues import 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")
    #进程列表
    t_list = []
    #创建进程
    # t1=MyProcess("t1")
    # t2=MyProcess("t2")
    # t3=MyProcess("t3")
    # t1.start()
    # t2.start()
    # t3.start()
    #使用for循环
    for i in range(3):
        t = MyProcess(f"t{i}",mq)
        t_list.append(t)
        t.start()

老师麻烦你帮我看一下

老师，请问，没有明白生成器是什么意思，为什么调用这个函数返回的是一个生成器呢

from time import sleep
def consumer():
    for i in range(6):
        print(f"生产了第{i}个产品")
        yield
        
def producter():
    g= consumer()
    next(g)
    for i in range(5):
        print(f"消费了第{i}个产品")
        next(g)
if __name__ == "__main__":
    producter()

老师 这个消费者与生产者这样 也可以实现啊  为什么得用send

多线程代码：

平常代码:

问题：

上面的多线程代码需要2秒，下面的需要20秒，老师我有一个疑惑，python中的多线程其实在一个时刻只有拿到锁 的线程才能执行，因此这10个线程 都要执行完sleep()函数，所以按我理解多线程代码也需要20秒，但实际却只要2秒，这是为什么？难道sleep函数有什么特别的地方吗？ 

老师，我想问一下我理解的对不对：就按视频里面讲的，如果在代码里开始四个线程，而且他们执行的是一个不能再线程规定执行时间执行完的任务，那么这四个线程拿着count=0的值，四个在同一优先级下抢夺全局锁，在一番抢夺全局锁和执行真实操作系统里面线程（即执行count+=1任务）之后，有一个线程率先执行完for循环内容，然后把值返回来，由于这个count是全局变量，四个线程值都同步了，然后其他三个线程前边执行的count+=1就全都没有积累下来，然后继续所以会导致最终执行结果比正确结果要小；

然后那个在视频中出现过一次执行结果正确的情况是因为可能当时cpu很快，在它们抢到锁以后，所有线程都在规定时间完成了任务，所以结果是对的，可以这么理解吗？

老师这里是只有定义这个run方法这个名才能在这个类里被自动调用执行么

这个是接收什么                                                                 

请问下我这个运行后为什么没结果测试greenlet切换

from time import time
from greenlet import greenlet
def func1():
    num=0
    for i in range(10000000):
        num+=1
        g2.switch()

def func2():
    num=0
    for i in range(10000000):
        num+=1
        g1.switch()

if __name__ == '__main__':

    g1=greenlet(func1)
    g2=greenlet(func2)
    start=time()
    g1.switch()
    end=time()

    print(end-start)

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

import multiprocessing
import time


def func1(conn1):
    sub_info="Hello!"
    print(f"进程1--{multiprocessing.current_process().pid} 发送参数{sub_info}")
    time.sleep(1)
    conn1.send(sub_info)
    print(f"来自线程2:{conn1.recv()}")
    time.sleep(1)

def func2(conn2):
    sub_info="你好！"
    print(f"进程2--{multiprocessing.current_process().pid} 发送参数{sub_info}")
    time.sleep(1)
    conn2.send(sub_info)
    print(f"来自线程1：{conn2.recv()}")
    time.sleep(1)



if __name__ == '__main__':
    #创建管道
    conn1,conn2=multiprocessing.Pipe()
    #创建子进程
    process1=multiprocessing.Process(target=func1,args=("conn1",))
    process2=multiprocessing.Process(target=func2,args=("func2",))
    #启动进程
    process1.start()
    process2.start()

进程2--59024发送参数你好！

进程1--51220发送参数Hello!

Process Process-2:

Process Process-1:

Traceback (most recent call last):

Traceback (most recent call last):

  File "D:\Anaconda\anaconda3\envs\python\lib\multiprocessing\process.py", line 315, in _bootstrap

    self.run()

  File "D:\Anaconda\anaconda3\envs\python\lib\multiprocessing\process.py", line 108, in run

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

  File "D:\Pycharm\python学习\python系统化学习\网络与并发编程\Pipe实现进程间的通信.py", line 9, in func1

    conn1.send(sub_info)

  File "D:\Anaconda\anaconda3\envs\python\lib\multiprocessing\process.py", line 315, in _bootstrap

    self.run()

  File "D:\Anaconda\anaconda3\envs\python\lib\multiprocessing\process.py", line 108, in run

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

AttributeError: 'str' object has no attribute 'send'

  File "D:\Pycharm\python学习\python系统化学习\网络与并发编程\Pipe实现进程间的通信.py", line 17, in func2

    conn2.send(sub_info)

AttributeError: 'str' object has no attribute 'send'

这个哪里错了呢

import threading
import time
from queue import Queue
class Pro(threading.Thread):
    def run(self):
        global qu
        count=0
        while True:
            if qu.qsize()<1000:
                for i in range(100):
                    count+=1
                    msg="生成产品"+str(count)
                    qu.put(msg)
                    print(msg)
            time.sleep(1)
class Con(threading.Thread):
    def run(self):
        global qu
        while True:
            if qu.qsize()>100:
                for i in range(3):
                    msg=self.name+"消费了"+qu.get()
                    print(msg)
            time.sleep(1)
if __name__=="__main__":
    qu=Queue
    for i in range(500):
        qu.put("初始产品"+str(i),)
    for i in range(2):
        p=Pro()
        p.start()
    for i in range(5):
        c=Con()
        c.start()

代码跟老师的一样，为什么会报这样的错？？？？？？？？？？

Traceback (most recent call last):

  File "C:/Users/齐泉/PycharmProjects/1/test2.py", line 28, in <module>

    qu.put("初始产品"+str(i))

TypeError: put() missing 1 required positional argument: 'item'

Process finished with exit code 1

t=Thread(target=func1,args=(f"t{i+1}",))

老师我不理解f't{i+1}',   里的f与，  这里为什么要有f和逗号？