import time
import multiprocessing
def sing():
  while True:
    print("-----sing-----")
    time.sleep(1)
def dance():
  while True:
    print("-----dance-----")
    time.sleep(1)
def main():
  p1 = multiprocessing.Process(target=sing)
  p2 = multiprocessing.Process(target=dance)
  p1.start()
  p2.start()
if __name__ == "__main__":
  main()

-----sing-----
-----dance-----
-----sing-----
-----dance-----
-----sing-----
-----dance-----
......

from multiprocessing import Process
import osdef 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()

# 創(chuàng)建隊(duì)列：
from multiprocessing import Queue
q = Queue(3)
# 往隊(duì)列中添加數(shù)據(jù)：
q.put(xxx)
# 從隊(duì)列中獲取數(shù)據(jù)：
q.get()

from multiprocessing import Queue
import multiprocessing
def download_data(q):
  """模擬這是從網(wǎng)上下載數(shù)據(jù)"""
  data = [11, 22, 33]
  for i in data:
    q.put(i)
  print("數(shù)據(jù)下載完成")
def deal_data(q):
  """模擬處理從網(wǎng)上下載下來的數(shù)據(jù)"""
  data_list = []
  while True:
    data = q.get()
    data_list.append(data)
    if q.empty():
      break
  print("處理數(shù)據(jù)結(jié)束，數(shù)據(jù)為：", data_list)
def main():
  q = Queue(3)
  p1 = multiprocessing.Process(target=download_data, args=(q,))
  p2 = multiprocessing.Process(target=deal_data, args=(q,))
  p1.start()
  time.sleep(1)
  p2.start()
if __name__ == '__main__':
  main()

# 創(chuàng)建進(jìn)程池
from multiprocessing import Pool
po = Pool(3)

# 給進(jìn)程池傳遞任務(wù)和參數(shù)
po.asyn(sing, (num,))

# 讓進(jìn)程池等待子進(jìn)程執(zhí)行完
po.close()
po.join()

from multiprocessing import Pool
import os, time, random
def worker(msg):
  t_start = time.time()
  print("%s開始執(zhí)行,進(jìn)程號(hào)為%d" % (msg, os.getpid()))
  # random.random()隨機(jī)生成0~1之間的浮點(diǎn)數(shù)
  time.sleep(random.random() * 2)
  t_stop = time.time()
  print(msg, "執(zhí)行完畢，耗時(shí)%0.2f" % (t_stop - t_start))
def main():
  po = Pool(3) # 定義一個(gè)進(jìn)程池，最大進(jìn)程數(shù)3
  for i in range(0, 10):
    # Pool().apply_async(要調(diào)用的目標(biāo),(傳遞給目標(biāo)的參數(shù)元祖,))
    # 每次循環(huán)將會(huì)用空閑出來的子進(jìn)程去調(diào)用目標(biāo)
    po.apply_async(worker, (i,))

  print("----start----")
  po.close() # 關(guān)閉進(jìn)程池，關(guān)閉后po不再接收新的請求
  po.join() # 等待po中所有子進(jìn)程執(zhí)行完成，必須放在close語句之后
  print("-----end-----")
if __name__ == '__main__':
  main()

----start----
0開始執(zhí)行,進(jìn)程號(hào)為7812
1開始執(zhí)行,進(jìn)程號(hào)為9984
2開始執(zhí)行,進(jìn)程號(hào)為1692
執(zhí)行完畢，耗時(shí)0.65
3開始執(zhí)行,進(jìn)程號(hào)為9984
執(zhí)行完畢，耗時(shí)1.08
4開始執(zhí)行,進(jìn)程號(hào)為7812
執(zhí)行完畢，耗時(shí)1.82
5開始執(zhí)行,進(jìn)程號(hào)為1692
執(zhí)行完畢，耗時(shí)1.12
6開始執(zhí)行,進(jìn)程號(hào)為7812
執(zhí)行完畢，耗時(shí)1.35
7開始執(zhí)行,進(jìn)程號(hào)為9984
執(zhí)行完畢，耗時(shí)0.11
8開始執(zhí)行,進(jìn)程號(hào)為9984
執(zhí)行完畢，耗時(shí)0.50
9開始執(zhí)行,進(jìn)程號(hào)為7812
執(zhí)行完畢，耗時(shí)0.65
執(zhí)行完畢，耗時(shí)0.70
執(zhí)行完畢，耗時(shí)0.74
-----end-----

import os
from multiprocessing import Pool
def copy_file(file, old_folder, new_folder):

  old_f = open(old_folder+"/"+file, "rb")
  data = old_f.read()
  old_f.close()

  new_f = open(new_folder+"/"+file, "wb")
  new_f.write(data)
  new_f.close()
  print("創(chuàng)建文件成功:", file)
def main():
  # 1.獲取要拷貝的文件夾
  old_folder = input("請輸入你要拷貝的文件夾：")
  # 2.創(chuàng)建新文件夾
  new_folder = old_folder + "_復(fù)件"
  try:
    os.mkdir(new_folder)
    print("創(chuàng)建文件夾成功")
  except Exception as e:
    pass
  # 3.獲取文件夾中所有待拷貝的文件,listdir()
  files_list = os.listdir(old_folder)
  # print(files_list)
  # 4.創(chuàng)建進(jìn)程池
  po = Pool(5)
  for file in files_list:
    # 向進(jìn)程池中添加復(fù)制文件的任務(wù)
    po.apply_async(copy_file, args=(file, old_folder, new_folder))
  # 復(fù)制原文件夾中的文件，到新文件夾中
  po.close()
  po.join()
if __name__ == '__main__':
  main()

import os
from multiprocessing import Pool, Manager
def copy_file(q, file, old_folder, new_folder):
  old_f = open(old_folder+"/"+file, "rb")
  data = old_f.read()
  old_f.close()
  new_f = open(new_folder+"/"+file, "wb")
  new_f.write(data)
  new_f.close()
  q.put(file)
def main():
  # 1.獲取要拷貝的文件夾
  old_folder = input("請輸入你要拷貝的文件夾：")
  # 2.創(chuàng)建新文件夾
  new_folder = old_folder + "_復(fù)件"
  try:
    os.mkdir(new_folder)
    print("創(chuàng)建文件夾成功")
  except Exception as e:
    pass
  # 3.獲取文件夾中所有待拷貝的文件,listdir()
  files_list = os.listdir(old_folder)
  # 4.創(chuàng)建進(jìn)程池
  po = Pool(5)
  # 5.創(chuàng)建隊(duì)列
  q = Manager().Queue()
  # 6.復(fù)制原文件夾中的文件，到新文件夾中
  for file in files_list:
    # 向進(jìn)程池中添加復(fù)制文件的任務(wù)
    po.apply_async(copy_file, args=(q, file, old_folder, new_folder))
  all_file_len = len(files_list)
  po.close()
  # po.join()
  copy_ok_file_num = 0
  while True:
    file = q.get()
    copy_ok_file_num += 1
    print("已拷貝文件%.2f %%" % (copy_ok_file_num*100/all_file_len))
    # print("\r已拷貝文件%.2f %%" % (copy_ok_file_num*100/all_file_len), end="")
    if copy_ok_file_num >= all_file_len:
      break
  print()
if __name__ == '__main__':
  main()