快捷導(dǎo)航

python進(jìn)程的狀態(tài)、創(chuàng)建及使用方法詳解

更新時(shí)間：2019年12月06日 09:40:45 作者：xlengji

這篇文章主要介紹了python進(jìn)程的狀態(tài)、創(chuàng)建及使用方法,結(jié)合實(shí)例形式詳細(xì)分析了Python進(jìn)程的概念、原理、工作狀態(tài)、創(chuàng)建以及使用方法,需要的朋友可以參考下

本文實(shí)例講述了python進(jìn)程的狀態(tài)、創(chuàng)建及使用方法。分享給大家供大家參考，具體如下：

進(jìn)程以及狀態(tài)

1. 進(jìn)程

程序：例如xxx.py這是程序，是一個(gè)靜態(tài)的

進(jìn)程：一個(gè)程序運(yùn)行起來(lái)后，代碼+用到的資源稱之為進(jìn)程，它是操作系統(tǒng)分配資源的基本單元。

不僅可以通過(guò)線程完成多任務(wù)，進(jìn)程也是可以的

2. 進(jìn)程的狀態(tài)

工作中，任務(wù)數(shù)往往大于cpu的核數(shù)，即一定有一些任務(wù)正在執(zhí)行，而另外一些任務(wù)在等待cpu進(jìn)行執(zhí)行，因此導(dǎo)致了有了不同的狀態(tài)

就緒態(tài)：運(yùn)行的條件都已經(jīng)慢去，正在等在cpu執(zhí)行
執(zhí)行態(tài)：cpu正在執(zhí)行其功能
等待態(tài)：等待某些條件滿足，例如一個(gè)程序sleep了，此時(shí)就處于等待態(tài)

進(jìn)程的創(chuàng)建-multiprocessing

multiprocessing模塊就是跨平臺(tái)版本的多進(jìn)程模塊，提供了一個(gè)Process類來(lái)代表一個(gè)進(jìn)程對(duì)象，這個(gè)對(duì)象可以理解為是一個(gè)獨(dú)立的進(jìn)程，可以執(zhí)行另外的事情

1. 2個(gè)while循環(huán)一起執(zhí)行

# -*- coding:utf-8 -*-
from multiprocessing import Process
import time
def run_proc():
  """子進(jìn)程要執(zhí)行的代碼"""
  while True:
    print("----2----")
    time.sleep(1)
if __name__=='__main__':
  p = Process(target=run_proc)
  p.start()
  while True:
    print("----1----")
    time.sleep(1)

說(shuō)明

創(chuàng)建子進(jìn)程時(shí)，只需要傳入一個(gè)執(zhí)行函數(shù)和函數(shù)的參數(shù)，創(chuàng)建一個(gè)Process實(shí)例，用start()方法啟動(dòng)

2. 進(jìn)程pid

# -*- coding:utf-8 -*-
from multiprocessing import Process
import os
import time
def run_proc():
  """子進(jìn)程要執(zhí)行的代碼"""
  print('子進(jìn)程運(yùn)行中，pid=%d...' % os.getpid()) # os.getpid獲取當(dāng)前進(jìn)程的進(jìn)程號(hào)
  print('子進(jìn)程將要結(jié)束...')
if __name__ == '__main__':
  print('父進(jìn)程pid: %d' % os.getpid()) # os.getpid獲取當(dāng)前進(jìn)程的進(jìn)程號(hào)
  p = Process(target=run_proc)
  p.start()

3. Process語(yǔ)法結(jié)構(gòu)如下：

Process([group [, target [, name [, args [, kwargs]]]]])

target：如果傳遞了函數(shù)的引用，可以任務(wù)這個(gè)子進(jìn)程就執(zhí)行這里的代碼
args：給target指定的函數(shù)傳遞的參數(shù)，以元組的方式傳遞
kwargs：給target指定的函數(shù)傳遞命名參數(shù)
name：給進(jìn)程設(shè)定一個(gè)名字，可以不設(shè)定
group：指定進(jìn)程組，大多數(shù)情況下用不到

Process創(chuàng)建的實(shí)例對(duì)象的常用方法：

start()：?jiǎn)?dòng)子進(jìn)程實(shí)例（創(chuàng)建子進(jìn)程）
is_alive()：判斷進(jìn)程子進(jìn)程是否還在活著
join([timeout])：是否等待子進(jìn)程執(zhí)行結(jié)束，或等待多少秒
terminate()：不管任務(wù)是否完成，立即終止子進(jìn)程

Process創(chuàng)建的實(shí)例對(duì)象的常用屬性：

name：當(dāng)前進(jìn)程的別名，默認(rèn)為Process-N，N為從1開(kāi)始遞增的整數(shù)
pid：當(dāng)前進(jìn)程的pid（進(jìn)程號(hào)）

4. 給子進(jìn)程指定的函數(shù)傳遞參數(shù)

# -*- coding:utf-8 -*-
from multiprocessing import Process
import os
from time import sleep
def run_proc(name, age, **kwargs):
  for i in range(10):
    print('子進(jìn)程運(yùn)行中，name= %s,age=%d ,pid=%d...' % (name, age, os.getpid()))
    print(kwargs)
    sleep(0.2)
if __name__=='__main__':
  p = Process(target=run_proc, args=('test',18), kwargs={"m":20})
  p.start()
  sleep(1) # 1秒中之后，立即結(jié)束子進(jìn)程
  p.terminate()
  p.join()

運(yùn)行結(jié)果:

子進(jìn)程運(yùn)行中，name= test,age=18 ,pid=45097...
{'m': 20}
子進(jìn)程運(yùn)行中，name= test,age=18 ,pid=45097...
{'m': 20}
子進(jìn)程運(yùn)行中，name= test,age=18 ,pid=45097...
{'m': 20}
子進(jìn)程運(yùn)行中，name= test,age=18 ,pid=45097...
{'m': 20}
子進(jìn)程運(yùn)行中，name= test,age=18 ,pid=45097...
{'m': 20}

5. 進(jìn)程間不同享全局變量

# -*- coding:utf-8 -*-
from multiprocessing import Process
import os
import time
nums = [11, 22]
def work1():
  """子進(jìn)程要執(zhí)行的代碼"""
  print("in process1 pid=%d ,nums=%s" % (os.getpid(), nums))
  for i in range(3):
    nums.append(i)
    time.sleep(1)
    print("in process1 pid=%d ,nums=%s" % (os.getpid(), nums))
def work2():
  """子進(jìn)程要執(zhí)行的代碼"""
  print("in process2 pid=%d ,nums=%s" % (os.getpid(), nums))
if __name__ == '__main__':
  p1 = Process(target=work1)
  p1.start()
  p1.join()
  p2 = Process(target=work2)
  p2.start()

運(yùn)行結(jié)果:

in process1 pid=11349 ,nums=[11, 22]
in process1 pid=11349 ,nums=[11, 22, 0]
in process1 pid=11349 ,nums=[11, 22, 0, 1]
in process1 pid=11349 ,nums=[11, 22, 0, 1, 2]
in process2 pid=11350 ,nums=[11, 22]