多任务-总结

1.线程

from threading import Thread

t = Thread(target=work1, args=(x,), kwargs={'x':'y'})

t.start()

2.多线程之间共享数据-全局变量，传参

传参只能使用可变类型的

3.自定义线程类

定义一个类，继承Thread

class func(Thread):

    创建run方法

    def run(self):

        pass

f = func()

f.start() 调用start方法会自动执行run方法

进程

1.导入进程模块

from multiprocessing import Process

#  创建进程对象

p = Process(target=work, args=(x,), kwargs={'x':'y'})

# 开启start

p.start()

2. 进程之间不能共享数据，要想让进程间通信，可以使用消息队列Queue

Queue是进程模块中的一个类

创建队列对象

q = Queue(3)  3表示最大最大能接收三条消息

放入数据

q.put()  括号里面可以放任意类型的数据

q.get()  数据一个一个取出来，当没有数据的时候会等待数据放入，并不会报错

q.empty()  判断队列里面数据是否为空

q.full()  判断队列里面数据是否已经放满

q.qsize() 显示当前队列里面的消息数量

q.put_nowait()

q.get_nowait()  当没有数据要取的时候，会报错，提示empty

3. 进程池：进程可以动态创建，但是当需要的进程数量较多时，手动创建会很浪费时间，这时候，可以使用进程池，

预先创建多个进程，此时进程池里面的进程结束后也不会被销毁

  1.导入进程模块中的Pool类

  from multiprocessing import Pool

  2.创建进程池对象

  po = Pool(3)  3表示能接收的最大进程数

  3.使用非阻塞的方式调用函数，执行顺序是无序的，异步  同步是指使用阻塞的方式执行，会排队等待

  po.apply_async(函数名, (x,y,), {'x':'y'}) 异步，非阻塞，无序

  4.po.close()  关闭进程池

    po.terminate()  不管任务有没有执行完成，都会立即终止

  5.po.join()  主进程等待子进程结束，必须放在close或是terminate之后

4. 进程池消息队列

  导入进程模块中的Manager()

  from multiprocessing import Pool, Manager

  q = Manager().Queue()

  其它用法与进程中消息队列用法一样

5.目前用到的关闭的地方有

文件的关闭

套接字的关闭

进程池的关闭