一、進程
1.1、方式一
from multiprocessing import Process
import time
#方式一
def task(name):
print(f"my name is {name},啟動時間")
time.sleep(2)
print(f"my name is {name},停止時間")
if __name__ == '__main__':
# 1 創建一個對象
p = Process(target=task, args=('jason',))
# 容器類型哪怕里面只有1個元素 建議要用逗號隔開 args=('jason',)
# 2 開啟進程
p.start() # 告訴操作系統幫你創建一個進程 異步
print('主進程')
'''
Windows操作系統下,創建進程一定要在main中創建
因為Windows下創建的進程類似於模塊導入的方式
代碼會從上往下依次執行
'''
1.2、方式二
class MyProcess(Process):
def run(self):
print('hello bf girl')
time.sleep(1)
print('get out!')
if __name__ == '__main__':
p = MyProcess()
p.start()
print('主進程')
總結:
- 創建進程就是在內存中申請一塊內存空間將需要運行的代碼丟進去
- 一個進程對應在內存中就是一塊獨立的內存空間
- 多個進程對應在內存中就是多塊獨立的內存空間
- 進程與進程之間數據默認情況下是無法直接交互,如果想交互可以借助於第三方工具、模塊
1.3、join方法
- join是讓主進程等待子進程代碼運行結束之后,再繼續運行。不影響其他子進程的執行
from multiprocessing import Process
import time
def task(name, n):
print('%s is running'%name)
time.sleep(n)
print('%s is over'%name)
if __name__ == '__main__':
# p1 = Process(target=task, args=('x', 1))
# p2 = Process(target=task, args=('c', 2))
# p3 = Process(target=task, args=('v', 3))
# start_time = time.time()
# p1.start()
# p2.start()
# p3.start() # 僅僅是告訴操作系統要創建進程
# p.join() # 主進程等待子進程p運行結束之后再繼續往后執行
# p1.join()
# p2.join()
# p3.join()
start_time = time.time()
p_list = []
for i in range(1, 4):
p = Process(target=task, args=('子進程%s'%i, i))
p.start()
p_list.append(p)
for p in p_list:
p.join()
print('主', time.time() - start_time)
1.4、進程之間數據相互隔離
from multiprocessing import Process
money = 100
def task():
global money # 局部修改全局
money = 666
print('子',money)
if __name__ == '__main__':
p = Process(target=task)
p.start()
p.join()
print(money)