zoukankan      html  css  js  c++  java
  • python多进程,多线程实例

    多进程和多线程总是傻傻分不清,查阅资料得知主要区别有两点

    • 一个进程可能包含多个线程,也就是线程概念小于进程
    • 多线程共享进程数据,共享简单,但同步复杂,相反,多线程数据是分开,但同步简单

    多进程

    多进程我一遍会使用multiprocessing包

    from multiprocessing import Process
    def fun1(name):
        print('测试%s多进程' %name)
    if __name__ == '__main__':
        process_list = []
        for i in range(5):  #开启5个子进程执行fun1函数
            p = Process(target=fun1,args=('Python',)) #实例化进程对象
            p.start()
            process_list.append(p)
    
        for i in process_list:
            p.join()
    
        print('结束测试')
    
    

    join()方法可以在当前位置阻塞主进程,带执行join()的进程结束后再继续执行主进程的代码逻辑,也就是说,加了join(),主进程会等待在这里直到多进程执行完毕,再执行。 不加join,主程序会继续执行,不会等待多进程结束

    除了直接写进程,还能使用进程池

    from  multiprocessing import Process,Pool
    def fun1(name):
        print('Run task %s (%s)...' % (name, os.getpid()))
        start = time.time()
        time.sleep(random.random() * 3)
        end = time.time()
        print('Task %s runs %0.2f seconds.' % (name, (end - start)))
    if __name__=='__main__':
        pool = Pool(5) #创建一个5个进程的进程池
        for i in range(10):
            pool.apply_async(func=fun1, args=(i,))   #apply是同步,apply_async是异步
        pool.close()
        pool.join()
        print('结束测试')
    

    多线程

    多线程我一般会用threading

    import threading
    def fun1(name):
        print('测试%s多线程' %name)
    if __name__ == '__main__':
        for i in range(10):
            t = threading.Thread(target=fun1, args=(str(i),))
            t.start()
    
  • 相关阅读:
    Python Web框架Django (三)
    谷歌把域名标记为不安全的解决办法
    tkmybatis VS mybatisplus
    jdbc预编译实现方式
    分析mybatis中 #{} 和${}的区别
    实体类id的几种生成方式
    java 获取mac地址
    javafx 表格某一列设置未复选框
    关闭在chrome里使用双指前进后退页面的功能
    调试maven源代码
  • 原文地址:https://www.cnblogs.com/peng-yuan/p/15182545.html
Copyright © 2011-2022 走看看