进程的定义和常用方法

import os
from multiprocessing import Process
from time import sleep

m = 1
list1 = []


def task1(s, name):
    global m
    while True:
        sleep(1)
        m += 1
        print("进程1", m)
        list1.append(str(m) + "task1")
        print(list1)
        print("------------>1", "进程号：{}，进程名字：{}，父进程号：{}".format(os.getpid(), name, os.getppid()))


def task2(s, name):
    while True:
        sleep(2)
        print("进程2", m)
        list1.append(str(m) + "task2")
        print(list1)
        print("------------>2", "进程号：{}，进程名字：{}，父进程号：{}".format(os.getpid(), name, os.getppid()))


if __name__ == '__main__':
    print(os.getpid(), "进程号：{}，父进程号：{}".format(os.getpid(), os.getppid()))
    p1 = Process(target=task1, name="任务1", args=(2, "小明"))
    p1.start()
    print(p1.name)

    p2 = Process(target=task2, name="任务2", args=(1, "小尼"))
    p2.start()
    print(p2.name)

    print("~~~~~~~~~~~~~~~~~~~~~~~")

自定义进程

from multiprocessing import Process
from time import sleep


class MyPro(Process):
    n = 1

    def __init__(self, name):
        super().__init__()
        self.name = name

    def run(self):
        global n
        while True:
            print("{},自定义进程{}".format(self.name, self.n))
            self.n += 1


if __name__ == '__main__':
    pro = MyPro("小明")
    pro.start()

进程池(task,args)--非阻塞式

设置进程数量，进程复用

非阻塞式：

直接把任务添加给进程，不需要等待

import os
import time
from multiprocessing import Pool
from random import random


def task(task_name):
    print("开始做任务了：{}".format(task_name))
    start = time.time()
    time.sleep(random() * 2)
    end = time.time()
    print("任务{}用时：{},______>id:{}".format(task_name, (end - start), os.getpid()))


if __name__ == '__main__':
    pool = Pool(5)
    list1 = ["听音乐", "跑步", "看孩子", "打游戏", "散步", "洗衣服"]
    for i in list1:
        pool.apply_async(task, args=(i,))

    pool.close()
    pool.join()
    print("over~~~~~~~~~~~~~~~~~~~")

进程池(task,args,callback)

import os
import time
from multiprocessing import Pool
from random import random


def task(task_name):
    print("开始做任务了：{}".format(task_name))
    start = time.time()
    time.sleep(random() * 2)
    end = time.time()
    return "任务{}用时：{},______>id:{}".format(task_name, (end - start), os.getpid())


con = []


def func(n):
    con.append(n)


if __name__ == '__main__':
    pool = Pool(5)
    list1 = ["听音乐", "跑步", "看孩子", "打游戏", "散步", "洗衣服"]
    for i in list1:
        pool.apply_async(task, args=(i,), callback=func)

    pool.close()
    pool.join()

    for i in con:
        print(i)
    print("over~~~~~~~~~~~~~~~~~~~")

进程池(task,args)--阻塞式

import os
import time
from multiprocessing import Pool
from random import random

con = []


def task(task_name):
    print("{}---开始做任务,进程Id:{}".format(task_name, os.getpid()))
    start = time.time()
    time.sleep(random() * 2)
    end = time.time()
    print("{}任务结束了,用时{}".format(task_name, (end - start)))


if __name__ == '__main__':
    pool = Pool(5)
    list1 = ["洗衣服", "吃饭", "打豆豆", "喝酒", "喝饮料", "跑步"]
    for ll in list1:
        pool.apply(task, args=(ll,))

    pool.close()
    pool.join()
    print("---------------over")

进程间的通信

from multiprocessing import Queue
from multiprocessing import Process
from time import sleep


def down_load(queue):
    images = ['girl.jpg', 'boy.jpg', 'man.jpg']
    for image in images:
        print("正在下载{}".format(image))
        sleep(0.5)
        queue.put(image)


def getfile(queue):
    while True:
        try:
            file = queue.get(timeout=5)
            print("{}文件保存成功！".format(file))
        except:
            break


if __name__ == '__main__':
    queue = Queue(5)
    p1 = Process(target=down_load, args=(queue,))
    p2 = Process(target=getfile, args=(queue,))
    p1.start()
    p2.start()