python修炼day32！

    
    今日内容概述：
    多进程实现文件夹下载、迭代器、生成器、协程
    昨日回顾
    程序：一个静态的概念
    进程：一个动态的概念，就是程序运行起来的状态，用于一定的资源
    线程：运行在进程之内，依赖于进程，
    进程和线程区别：
    共同点：都可以完成多任务区别：    线程：  threading        依赖于进程        多线程之间共享全局的变量        主线程等待子线程结束，才结束        系统开销较小    进程： multiprocessing        运行起来的应用程序，占有一些资源        写时拷贝，进程不共享全局的资源        通过队列实现进程间通信        系统开销比较大
    进程的创建：
    multiprocessing．Process（target＝函数名，args＝（参数））继承方式创建进程class 子类名（multiprocessing．Proces）：    def run（self）：        pass
    进程间通信（传递数据 ）：
    q ＝ multiprocessing．Queue（3）      ＃ 创建一个队列，可以指定可传递几个数据q．put （）   ＃ 存    q．get（）     ＃ 取     q．qsize（）  ＃ 取消息数量   q．full（）  ＃ 判断是否满了q．empty  ＃ 判断是否为空
    进程池：
    一个特殊的容器，里面创建了很多进程，重复利用进程作用：减少了创建，销毁进程的过程，提高了效率po ＝  multiprocessing．Pool（3）  ＃ 定义一个进程池，最大进程数2po．apply＿async（要调用的目标，（要传递的参数））  ＃ async 异步po．close（）   ＃ 关闭进程池po．join（）   ＃ 等待所有的子进程执行完毕
    今日内容
    文件夹复制：
    os．listdir（）  ＃ 列出文件夹中所有的文件名os．path．getsize（）  ＃ 获取文件的大小os．mkdir（）  ＃ 新建文件夹Pool（）  ＃ 创建进程池Manger（）．Queue（）  ＃ 有进程池的时候，队列需要 Manger（）中的Queue（）    with open（＂文件名＂， “rw”） as f：    f．read（）  ＃ 读    f．write（）  ＃ 写
    文件夹复制代码
    import multiprocessing
    import os， time
    def save＿folder（q， dw＿folder＿name， save＿folder＿name， file＿name）：
    with open（dw＿folder＿name ＋ ＂／＂ ＋ file＿name， ＂rb＂） as f：
    content ＝ f．read（）
    ＃ 在新创建的文件中写入文件
    with open（save＿folder＿name ＋ ＂／＂ ＋ file＿name， ＂wb＂） as f2：
    f2．write（content）
    new＿file＿size ＝ os．path．getsize（save＿folder＿name ＋ ＂／＂ ＋ file＿name）
    q．put（new＿file＿size）
    def main（）：
    ＃ 提示用户输入文件夹名
    dw＿folder＿name ＝ input（＂请输入要下载的文件夹的名字：＂）
    try：
            ＃ 创建一个新文件夹
            save＿folder＿name ＝ dw＿folder＿name ＋ ＂［嘿嘿嘿］＂
            os．mkdir（save＿folder＿name）
    except：
    pass
    ＃ 获取目标文件夹中的所有的文件　os．listdir（）
    file＿names ＝ os．listdir（dw＿folder＿name）
    ＃ 添加进程池
    po ＝ multiprocessing．Pool（3）
    ＃ 创建队列
    q ＝ multiprocessing．Manager（）．Queue（）
    ＃ 从目标文件夹中读取文件
    for file＿name in file＿names：
            po．apply＿async（save＿folder， （q， dw＿folder＿name， save＿folder＿name， file＿name））
    po．close（）
    ＃ po．join（）
    ＃ 获取文件夹的大小
    folder＿size ＝ 0
    for old＿file in file＿names：
    old＿file＿s ＝ os．path．getsize（dw＿folder＿name ＋ ＂／＂ ＋ old＿file）
    folder＿size ＋＝ old＿file＿s
    print（＂文件夹总大小为：　％d＂ ％ folder＿size）
    new＿file＿size ＝ 0
    ＃ 显示进度
    while True：
    s ＝ q．get（）
            new＿file＿size ＋＝ s
            time．sleep（0．1）
            print（＂拷贝的进度为： ％．2f ％％＂ ％ （new＿file＿size ／ folder＿size ＊ 100）， end＝＂＂）
            if new＿file＿size ＞＝ folder＿size：
    break
    print（）
    if ＿＿name＿＿ ＝＝ ＂＿＿main＿＿＂：
    main（）
    进程池中的进程出现异常不会显示
    
    
    1  2  下一页>