方法一

from multiprocessing import Process  def worker_function(name):  print(f"Worker {name} is working")  if __name__ == "__main__":  # 创建进程实例  p1 = Process(target=worker_function, args=("Process 1",))  p2 = Process(target=worker_function, args=("Process 2",))  # 启动进程  p1.start()  p2.start()  # 等待进程结束  p1.join()  p2.join()  print("All processes done.")

方法二 继承

from multiprocessing import Process
import timeclass MyProcess(Process):def run(self):print('into process ……')time.sleep(1)p = MyProcess()
p.start()
print("---主---")

三、使用Pool创建进程池

from multiprocessing import Pool  def worker_function(num):  return num * num  if __name__ == "__main__":  # 创建一个进程池，包含4个进程  with Pool(processes=4) as pool:  # 使用map方法分发任务到进程池  results = pool.map(worker_function, [1, 2, 3, 4, 5])  print(results)  # 输出: [1, 4, 9, 16, 25]

四、使用Process和管道进行进程间通信

from multiprocessing import Process, Pipe  def worker(conn):  print("Worker process started")  conn.send("Hello from worker!")  conn.close()  if __name__ == "__main__":  parent_conn, child_conn = Pipe()  p = Process(target=worker, args=(child_conn,))  p.start()  print("Parent process received:", parent_conn.recv())  p.join()

附加

# 杀死当前进程
p.terminate()
# 判断当前进程是否存活
p.is_alive()
p.daemon = True  # 将进程p设置成守护进程，放在p.start()前面，否则会报错# 互斥锁
from multiprocessing import Lockmutex = Lock()
for i in range(10):p = Process(target=run, args=(i, mutex))p.start()# 抢锁
mutex.acquire()
# 释放锁
mutex.release()