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传参他的作用是什么

from multiprocessing import Process,Pipe
import os

def fun1(name,con):
    print(f"当前进程号为{os.getpid()}接受的数据为{con.recv()}")
    con.send("nihao")
if __name__ == '__main__':

    print(f"著京城{os.getpid()}")
    con1, con2 = Pipe()
    p1=Process(target=fun1,args=("p1",con1))
    con2.send("hello")

    p1.join()
    print(con2.recv())
    
    #老师 这是哪部分出了问题

print(f"第{number}个人在安检")

这个f是什么意思

"""协程的基本使用-asyncio的task的使用"""
import functools
import asyncio
async def compute(x,y):
    print(f"compute:{x}+{y}....")
    await asyncio.sleep(1)
    return x+y

async def print_sum(x,y):
    #创建task
    task = asyncio.create_task(compute(x,y))
    #task绑定回调函数
    task.add_done_callback(functools.partial(end,x,y))
    #释放一下cpu的使用
    await asyncio.sleep(1)

def end(n,m,t):
    print(f"{n}+{m}={t.result}")

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(print_sum(2,3))
    loop.close()

这个是什么情况啊老师？？

求解

#协程的使用——gevent
import gevent
def gf(name):
    print(f'{name}:我想买包包！！！')
    gevent.sleep(1)
    print(f'{name}:我想学编程！！！')
    g2.switch()
def bf(name):
    print(f'{name}:买！买！买！！')
    gevent.sleep(1)
    print(f"{name}:一点更要去上学堂！")
if __name__ == '__main__':
    g1=gevent.spawn(gf,'貂蝉')
    g2=gevent.spawn(bf,'吕布')
    g1.join()
    g2.join()

老师我这是什么情况呀？

from threading import Thread,BoundedSemaphore

from time import sleep
def an_JIan(number):
    renshu.acquire()
    print(f"第{number}个人在安检")
    sleep(3)
    renshu.release()

if __name__ == '__main__':
    renshu=BoundedSemaphore(3)
    for x in range(10):
        t1=Thread(target=an_JIan,args=(f'{x+1}',))
        t1.start()

#老师我的运行结果每次不一样是怎么回事呢

'''

第1个人在安检

第2个人在安检

第3个人在安检

第4个人在安检

第6个人在安检

第5个人在安检

第8个人在安检

第7个人在安检

第9个人在安检

第10个人在安检

进程已结束，退出代码为 0

第二种如下：

第1个人在安检

第2个人在安检

第3个人在安检

第5个人在安检

第4个人在安检

第6个人在安检

第8个人在安检

第7个人在安检

第9个人在安检

第10个人在安检

进程已结束，退出代码为 0

'''

import asyncio
import functools


async def compute(x, y):
    print(f'compute:{x}+{y}...')
    await  asyncio.sleep(1)
    return x + y


async def print_sum(x, y):
    # 创建task
    task = asyncio.create_task(compute(x, y))  # 底层
    # task绑定事件函数
    task.add_done_callback(functools.partial(end, x, y))

    await  asyncio.sleep(1)


def end(n, m,t):
    # result = await compute(x,y)
    print(f'{n}+{m}={t.result}')


if __name__ == '__main__':
    loop = asyncio.get_event_loop()

    loop.run_until_complete(print_sum(1, 2))

    loop.close()

老师能把这个程序的流程叙述一遍吗 我调试了一下感觉还是不太懂

import asyncio
import functools


async def compute(x, y):
    print(f'compute:{x}+{y}...')
    await  asyncio.sleep(1)
    return x + y


async def print_sum(x, y):
    # 创建task
    task = asyncio.create_task(compute(x, y))  # 底层
    # task绑定事件函数
    task.add_done_callback(functools.partial(end, x, y))

    await  asyncio.sleep(1)


def end(n, m,t):
    # result = await compute(x,y)
    print(f'{n}+{m}={t.result}')


if __name__ == '__main__':
    loop = asyncio.get_event_loop()

    loop.run_until_complete(print_sum(1, 2))

    loop.close()

老师能把这个程序的流程叙述一遍吗 我调试了一下感觉还是不太懂

#他不可以fun2中在去调用fun1吗 为什么呢 老师

from threading import  RLock

def fun1():
    lock.acquire()
    print("fun1 ")
    fun2()
    lock.release()

def fun2():
    lock.acquire()
    print("%%%%%%%")

    lock.acquire()
    print("fun2")

    fun1()
    lock.release()

def fun3():
    print('####')
    fun1()
    fun2()

if __name__ == '__main__':

    lock = RLock()
    fun3()
    
    #老师好 为什么我这里他会报错呢

请问老师，Event.is_set()  刚开始判断True和Fslse  

也需要clear()和set（）来判断吗？

老师你好，是不是用锁的时候只要是  RLock()  就不会出现死锁？

不用啦 解决啦

不用啦 解决啦