Python進(jìn)程是什么？進(jìn)程知識(shí)點(diǎn)詳解

import multiprocess as m
m.Process(target，args)

from multiprocessing import Process
Process(group, target, args, kwargs, name)
group:用戶組
target:調(diào)用函數(shù)
args:參數(shù)元祖
kwargs:參數(shù)字典
name:子進(jìn)程名稱

# 返回當(dāng)前進(jìn)程存活的子進(jìn)程的列表。調(diào)用該方法有“等待”已經(jīng)結(jié)束的進(jìn)程的副作用。
multiprocessing.active_children()
 
 
# 返回系統(tǒng)的CPU數(shù)量。
multiprocessing.cpu_count()

#啟動(dòng)進(jìn)程，調(diào)用進(jìn)程中的run()方法。
start()
 
 
#進(jìn)程活動(dòng)的方法
run()
 
 
#強(qiáng)制終止進(jìn)程，不會(huì)進(jìn)行任何清理操作。如果終止前創(chuàng)建了子進(jìn)程，那么該子進(jìn)程在其強(qiáng)制結(jié)束后變?yōu)榻┦M(jìn)程；如果該進(jìn)程還保存了一個(gè)鎖，那么也將不會(huì)被釋放，進(jìn)而導(dǎo)致死鎖。
terminate()
 
 
#判斷某進(jìn)程是否存活，存活返回True，否則False。
is_alive()
 
 
主線程等待子線程終止。timeout為可選擇超時(shí)時(shí)間；需要強(qiáng)調(diào)的是：p.join只能join住start開(kāi)啟的進(jìn)程，而不能join住run開(kāi)啟的進(jìn)程。
join([timeout])
 
 
#設(shè)置進(jìn)程為后臺(tái)守護(hù)進(jìn)程；當(dāng)該進(jìn)程的父進(jìn)程終止時(shí)，該進(jìn)程也隨之終止，并且該進(jìn)程不能創(chuàng)建子進(jìn)程，設(shè)置該屬性必須在start()之前
daemon
 
 
#進(jìn)程名稱。
name
 
 
#進(jìn)程pid，在start后才能產(chǎn)生
pid
 
 
#子進(jìn)程的退出代碼。如果進(jìn)程尚未終止，這將是 None，負(fù)值-N表示子進(jìn)程被信號(hào)N終止。
exitcode
 
 
#進(jìn)程身份驗(yàn)證，默認(rèn)是os.urandom()隨機(jī)生成的字符串。校驗(yàn)網(wǎng)進(jìn)程連接是否正確
authkey
 
 
#系統(tǒng)對(duì)象的數(shù)字句柄，當(dāng)進(jìn)程結(jié)束時(shí)將變?yōu)?"ready" 。
sentinel
 
 
#殺進(jìn)程
kill()
 
 
#關(guān)閉進(jìn)程
close()

if __name__ == '__main__':

from multiprocessing import Pool
import multiprocessing as m

num=m.cpu_count()#CPU內(nèi)核數(shù)

pool=multiprocessing.Pool(num)

apply(func，args，kwargs)                 同步執(zhí)行（串行） 阻塞
 
 
apply_async(func，args，kwargs)           異步執(zhí)行（并行） 非阻塞
 
 
terminate()            強(qiáng)制終止進(jìn)程，不在處理未完成的任務(wù)。
 
 
join()     主進(jìn)程阻塞，等待子進(jìn)程的退出。必須在close或terminate()之后使用
 
 
close()            等待所有進(jìn)程結(jié)束后，才關(guān)閉進(jìn)程池
 
 
map(func，iterable，chunksize=int) map函數(shù)的并行版本，保持阻塞直到獲得結(jié)果
 
 
#返回一個(gè)可用于獲取結(jié)果的對(duì)象，回調(diào)函數(shù)應(yīng)該立即執(zhí)行完成，否則會(huì)阻塞負(fù)責(zé)處理結(jié)果的線程
map_async(func，iterable，chunksize，callback，error_callback)
 
 
imap(func，iterable，chunksize) map的延遲執(zhí)行版本
 
 
#和imap() 相同，只不過(guò)通過(guò)迭代器返回的結(jié)果是任意的
imap_unordered(func，iterable，chunksize)
 
 
#和 map() 類似，不過(guò) iterable 中的每一項(xiàng)會(huì)被解包再作為函數(shù)參數(shù)。
starmap(func，iterable，chunksize)

from multiprocessing import Lock

import time
lock1=RLock()
lock2=RLock()
s=time.time()
def jc(num):
    lock1.acquire()
    lock2.acquire()
    print('start')
    print(m.current_process().pid，'run----'，str(num))
    lock1.release()
    lock2.release()
    print('end')
if __name__ == '__main__':
    aa=[]
    for y in range(12):
        pp=Process(target=jc，args=(y，))
        pp.start()
        aa.append(pp)
    for x in aa:
        x.join()
    e=time.time()
    print(e-s)

import time
e=Event()
def main(num):
    while True:
        if num<5:
            e.clear()   #清空信號(hào)標(biāo)志
            print('清空')
        if num>=5:
            e.wait(timeout=1) #等待信號(hào)標(biāo)志為真
            e.set()
            print('啟動(dòng)')
            
        if num==10:
            e.wait(timeout=3)
            e.clear()
            print('退出')
            break
        num+=1
        time.sleep(2)
if __name__ == '__main__':
    for y in range(10):
        pp=Process(target=main，args=(y，))
        pp.start()
        pp.join()

p1，p2=m.Pipe(duplex=bool) #設(shè)置是否全雙工，返回兩個(gè)連接對(duì)象

p1.send()  #發(fā)送
p2.recv()  #接收
p1.close()  #關(guān)閉連接
p1.fileno() #返回連接使用的整數(shù)文件描述符
p1.poll([timeout]) #如果連接上的數(shù)據(jù)可用，返回True，timeout指定等待的最長(zhǎng)時(shí)限。
p2.recv_bytes([maxlength]) #接收最大字節(jié)數(shù)
p1.send_bytes([maxlength]) #發(fā)送最大字節(jié)數(shù)
#接收一條完整的字節(jié)消息，并把它保存在buffer對(duì)象中，offset指定緩沖區(qū)中放置消息處的字節(jié)位移.
p2.recv_bytes_into(buffer [， offset])

def fd(a):
    for y in range(10):
        a.put(y)  #插入數(shù)據(jù)
        print('插入：'，str(y))
def df(b):
    while True:
        aa=b.get(True) #刪除數(shù)據(jù)
        print('釋放：'，str(aa))
if __name__ == '__main__':
    q=Queue()
    ff=Process(target=fd，args=(q，))
    dd=Process(target=df，args=(q，))
    ff.start() #開(kāi)始運(yùn)行
    dd.start()
    dd.terminate() #關(guān)閉
    ff.join()

s=Semaphore(3)
s.acquire()
print(s.get_value())
s.release()
print(s.get_value())
print(s.get_value())
s.release()
print(s.get_value())
s.release()
 
 
output：
2
3
3
4

數(shù)值型：m.Value()  
數(shù)組性：m.Array()  
字典型：m.dict()  
列表型:m.list()

Manager().dict()
Manager.list()