并发编程（Process对象的join方法）(

一、 Process对象的join方法

在主进程运行过程中如果想并发地执行其他的任务，我们可以开启子进程，此时主进程的任务与子进程的任务分两种情况

情况一：在主进程的任务与子进程的任务彼此独立的情况下，主进程的任务先执行完毕后，主进程还需要等待子进程执行完毕，然后统一回收资源。

情况二：如果主进程的任务在执行到某一个阶段时，需要等待子进程执行完毕后才能继续执行，就需要有一种机制能够让主进程检测子进程是否运行完毕，在子进程执行完毕后才继续执行，否则一直在原地阻塞，这就是join方法的作用

阻塞当前进程，直到调用join方法的那个进程执行完，再继续执行当前进程。

#!/usr/bin/env python

# -*- coding:utf-8 -*-

import time

from  multiprocessing import Process

def task(name):

    print('%s is runing' % name)

    time.sleep(1)

    print('%s is done' % name)

if __name__ == '__main__':

    p1 = Process(target=task, args=('xiaojiu',))

    p2 = Process(target=task, args=('hh',))

    p3 = Process(target=task, args=('wawa',))

    p1.start()

    p1.join() #这里xiaojiu 执行完毕之后才会执行其他进程

    p2.start()

    p3.start()

    print('主进程')

#输出

xiaojiu is runing

xiaojiu is done

主进程

hh is runing

wawa is runing

hh is done

wawa is done

二、 Process对象的其他属性或方法

进程对象的其他方法一:terminate与is_alive

#!/usr/bin/env python

# -*- coding:utf-8 -*-

import time

from  multiprocessing import Process

def task(name):

    print('%s is runing' % name)

    time.sleep(1)

    print('%s is done' % name)

if __name__ == '__main__':

    p1 = Process(target=task, args=('xiaojiu',))

    p2 = Process(target=task, args=('hh',),name=('子进程2')) #改变进程名称

    p3 = Process(target=task, args=('wawa',))

    p1.start()

    # p1.join() #这里xiaojiu 执行完毕之后才会执行其他进程

    p1.terminate() #关闭进程，不会立即关闭，因为关闭的是进程信号。

    print(p1.is_alive()) #查看是否存活

    print(p1.name) #可以查看进程的名称 # Process-1

    print(p2.name) #子进程2

    print(p3.name)# Process-3

    p2.start()

    p3.start()

    print('主进程')

#输出

True

Process-1

子进程2

Process-3

主进程

hh is runing

wawa is runing

hh is done

wawa is done

巴特西

并发编程（Process对象的join方法）(

一、 Process对象的join方法

二、 Process对象的其他属性或方法

最新文章

热门文章