from multiprocessing import Process,current_process
from multiprocessing import Manager

def fun1(name,m_dict,m_list):
    print(f'子进程为{current_process().pid}接受的数据为{m_list}')
    print(f'子进程为{current_process().pid}接受的数据为{m_dict}')

    m_list.append('你好')
    m_dict['age']='18'

if __name__ == '__main__':
    print(f'主进程为{current_process().pid}')

    with Manager() as mul:
        m_list=mul.list()
        m_dict=mul.dict()
        m_dict['name']='俞兴志'
        m_list.append("hello12345")
        p1=Process(target=fun1,args=("p1",m_list,m_dict))
        p1.start()

        p1.join()
        print(m_list)
        print(m_dict)

#老师好 我有三个问题

#1为什么我这里是主线程结束 然后是先打印出来的是字典 再是列表

#2我在子线程添加了新的数据 控制台报错 原因是'DictProxy' object has no attribute 'append'（'DictProxy' 对象没有属性 'append'）

##3 p1=Process(target=fun1,args=("p1",m_list,m_dict)#后面args传参他的作用是什么

老师想请教下，Process类不是有了name属性吗，为什么继承了Process类还要再加一个name属性呢

我这是什么情况，老师，我不理解

老师所以这个echo服务指的是啥？？？？？？？？？？？？？？？？？？？？

老师，这样的操作怎么实现

from greenlet import greenlet
from time import time
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()
    end=time()
    print(end-start)

老师 我这个代码哪有问题 一值运行不出来

#tcp服务器
from socket import *
tcpsocket=socket(AF_INET,SOCK_STREAM)
tcpsocket.bind(("",7788)) #进行服务器ip端口绑定 ip不写默认本机地址
tcpsocket.listen(5) #服务器连接满了 可以排队5人
newSock,clienAddr=tcpsocket.accept() #等待请求连接
#创建一个新的套接字用来进行数据的收发 clienaddr客户端的地址
data=newSock.recv(1024)
newSock.send(b"xiexie")

newSock.close() #先关闭新的套接字
tcpsocket.close()

老师 这个newsock这个新的套接字就是用进行数据的发送与接受 而tcpsocket是用来监听连接请求的  clienaddr是返回客户端的地址  对吗

如何才能和我们输入的信息一样                           

Process finished with exit code 0

老师控制台只显示这个死怎么回事

老师为什么我的代码加入了mq.qsize()<10:后，没起作用，还是一直生产和购买下去，哪里出错了吗

from threading import Thread

from queue import Queue

from time import sleep

def producer():

num = 1

while True:

if mq.qsize() < 10:

print(f'生产了{num}号加菲猫')

mq.put(f'{num}号加菲猫')

num += 1

sleep(1)

def consumer():

while True:

print('购买了{}'.format(mq.get()))

sleep(2)

if __name__ == '__main__':

#共享数据的容器

mq=Queue()

#创建生产者线程

t1=Thread(target=producer)

#创建消费者线程

t2=Thread(target=consumer)

t3=Thread(target=consumer)

#开始工作

t1.start()

t2.start()

t3.start()

老师您好

from socket import *
import asyncio
# 给对方传递信息
s = socket(AF_INET, SOCK_DGRAM)  # ipv4协议 使用的是udp协议
s.bind(("", 5431))
addr = ("172.27.150.26", 8080)  # ip 地址和端口地址
async def fun1():
    while True:
        date = input("请输入要选择的内容")
        s.sendto(date.encode("gb2312"), addr)       # 将字符流转为字符串

async def fun2():
    while True:
        task = asyncio.create_task(fun1())
        task.add_done_callback()
        redate = s.recvfrom(10)
        print(redate[0].decode("gb2312"))
if __name__ == '__main__':
    f1 = fun1()
    f2 = fun2()
    loop = asyncio.get_event_loop()
    loop.run_until_complete(f2)
    loop.close()

我想用进程的方法实现它可以同时接受信息，请问要怎么做才行啊？

老师好 pycharm里面没有greenlet模块怎么操作呢

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


def producer():
num = 1
while True:
if mq.qsize() < 10:
print(f'生产了{num}号加菲猫')
mq.put(f'{num}号加菲猫')
num += 1 
sleep(1)


def consumer():
while True:
print('购买了{}'.format(mq.get()))
sleep(2)


if __name__ == '__main__':
#共享数据的容器
mq=Queue()
#创建生产者线程
t1=Thread(target=producer)
#创建消费者线程
t2=Thread(target=consumer)
t3=Thread(target=consumer)

#开始工作
t1.start()
t2.start()
t3.start()

附上源代码，老师

# coding = 'UTF-8'
from socket import *
# a = socket(AF_INET, SOCK_STREAM)  IPV4 TCP协议
a = socket(AF_INET, SOCK_DGRAM)  # IPV4  udp协议
a.sendto('Hello world !', ('192.168.1.115', 8080))  # send some information to sb.


为什么总是注释报错？加utf-8还是报错？

老师，为什么多线程所需要的的时间比睡眠时间 * n还要多一点？是因为切换线程需要时间吗？我的电脑CPU是8核，创建了10个线程，如果是，为什么有时候单线程后面的秒数又多些？

为什么每次运行时，打印出来的时间都是不一样的？