写点什么

聊聊 python 多线程与多进程

  • 2024-05-31
    湖南
  • 本文字数:1541 字

    阅读完需:约 5 分钟

为什么要使用多进程与多线程呢?

因为我们如果按照流程一步步执行任务实在是太慢了,假如一个任务就是 10 秒,两个任务就是 20 秒,那 100 个任务呢?况且 cpu 这么贵,时间长了就是浪费生命啊!一个任务比喻成一个人,别个做高铁,你做绿皮火车,可想而知!接下来我们先看个例子:

from random import randintfrom time import sleep,timedef download_task(file_name):    print('begin download file %s' %file_name)    spend_time=randint(5,10)    sleep(spend_time)    print('%s finish download spend time %d sencond' %(file_name,spend_time))
def main(): start=time() dowload_task('1.txt') dowload_task('2.txt') end=time() print('total time %.2f' %(end-start))
if __name__=='__main__': main()
复制代码

执行结果如下图:

都花费 13s 了。。。。。。。。,大无语好吧!

多进程

from multiprocessing import Processfrom random import randintfrom os import getpidfrom time import time,sleep
def download_task(file_name): print('begin download file %s' %file_name) spend_time=randint(5,10) sleep(spend_time) print('%s finish download spend time %d sencond' %(file_name,spend_time))
def main(): start=time() dowload_task('1.txt') dowload_task('2.txt') end=time() print('total time %.2f' %(end-start))
if __name__=='__main__': main()
复制代码

执行结果如下:

上面的代码就是通过 Process 类创建的进程对象,通过 target 参数传递一个需执行的函数,args 是要传入的传输,它是一个组。后面通过 start()来启动函数,join()等待函数结束,我们可以从出时间减少了很多,最后的时间不在是两个任务依次执行的综合了!

多线程

# /usr/bin/python3from random import randintfrom threading import Threadfrom time import time, sleepfrom os import getpid
def dowload_task(file_name): print("开始下载%s" % file_name) print("进程id %d" % getpid()) spend_time = randint(5, 10) sleep(spend_time) print("%s下载完成,耗费%ds" % (file_name, spend_time))

def main(): start = time() p1 = Thread(target=dowload_task, args=("1.txt",)) p1.start() p2 = Thread(target=dowload_task, args=("2.txt",)) p2.start() p1.join() p2.join() end = time() print("总共花费%ss" % (end - start))

if __name__ == "__main__": main()
复制代码

执行结果:

用 class 方式

# /usr/bin/python3from random import randintfrom threading import Threadfrom time import time, sleepfrom os import getpid

class Down_task(Thread): def __init__(self, file_name): super().__init__() self._file_name = file_name
def run(self): print("开始下载%s" % self._file_name) print("进程id %d" % getpid()) spend_time = randint(5, 10) sleep(spend_time) print("%s下载完成,耗费%ds" % (self._file_name, spend_time))

def main(): start = time() p1 = Down_task( "1.txt", ) p1.start() p2 = Down_task( "2.txt", ) p2.start() p1.join() p2.join() end = time() print("总共花费%ss" % (end - start))

if __name__ == "__main__": main()
复制代码

执行结果:

问题:

  1. 那你们知道进程与线程区别吗?

  2. 什么时候用线程什么时候用进程?

  3. 线程在做计算任务时,需要注意什么呢?


作者:李 MAX

链接:https://juejin.cn/post/7374668941653196826

用户头像

欢迎关注,一起学习,一起交流,一起进步 2020-06-14 加入

公众号:做梦都在改BUG

评论

发布
暂无评论
聊聊python多线程与多进程_Python_我再BUG界嘎嘎乱杀_InfoQ写作社区