manage 创建共享内容
生产者消费者模型使用场景
多道技术（不太清楚）
生产者消费者模型可以应用于多台机器上 分布式 可以多台计算器放着生产者，坏了几台也不影响，稳定。
如果有多个生产者消费者那么队列就要基于网络，应该做成套接字。
放在main下面导入问题——》开启子进程涉及到一个导入模块的问题，不放在main下start开启子进程导入时会把自己又执行一次，造成重复导入。
今日内容：
进程不是执行单位为什么可以执行代码？因为是里面的线程在执行
cpu切换切的是线程
1.什么是线程？为何有线程？怎么用线程？
线程指的是一条流水线的工作流程
进程不是一个执行单位是一个资源单位。
一个进程内自带一个线程，线程是执行单位。
qq进程：qq资源相关的数据占了一个独立的空间。（申请一个内存空间，中间产生的数据往里放）
每个进程内自带一个线程，线程才是cpu的执行单位
进程在运行本质是进程里的线程在执行
一个文件的执行：先开辟一个空间，生成的数据往里面丢
线程的执行：空间已经由进程造好了，直接运行就行了
线程是一个抽象的概念。（三个线程就是有三段代码在运行，三个进程就是有三个内存空间建立）
2.开启线程的两种方式 （*****）
开线程不需要写到main下，但是为了规范还是要写main。
3 线程vs进程 （*****）
同一进程内的线程们共享该进程内的资源，不同进程内的线程资源肯定是隔离的。
创建线程的开销比创建进程要小得多。
1、 线程中没有父子关系。相较于子线程、主线程特殊之处在于其代变了主进程的生命周期。
主进程等待子进程结束然后结束，是为子进程回收资源。
主线程等待子线程结束然后结束，是等待这个进程的代码（其他非守护线程）执行完毕。
方式一：导入Thread模块
from threading import Thread
import time
def task(name):
print('%s is running' %name)
time.sleep(3)
if __name__ == '__main__':
t=Thread(target=task,args=('egon',))
t.start()
print('主线程')
方式二：创建类继承Thread
from threading import Thread
import time
class MyThread(Thread):
def run(self):
print('%s is running' %self.name)
time.sleep(3)
if __name__ == '__main__':
t=MyThread()
t.start()
print('主线程')
1查看线程pid：一个进程中的线程pid是一样的
1、瞅一瞅PID （Process ID）
from threading import Thread
import time,os
def task():
print('%s is running' %os.getpid())
time.sleep(3)
if __name__ == '__main__':
t=Thread(target=task,)
t.start()
print('主线程',os.getpid()) #一个进程中的子线程pid相同
2 线程创建开销小：子进程创建不需要向操作系统申请内存空间，直接执行程序。
3.同一个进程中的多个线程共享进程的资源
from threading import Thread
import time,os
x=1000
def task():
global x
x=0
if __name__ == '__main__':
t=Thread(target=task,)
t.start()
t.join()
print('主线程',x) #主线程 0
线程的对象以及属性
查看当前线程名字（current_thread().name）,active_count() 查看当前活跃的线程数 ，获得线程对象 enumerate（），以及查看当前线程的pid
from threading import Thread,current_thread,active_count,enumerate
import time,os
def task():
print('%s is running' %current_thread().name) #Thread-1 is running
time.sleep(3)
print("%s is done"%os.getpid())
if __name__ == '__main__':
t1=Thread(target=task,name='第一个线程')
t2=Thread(target=task,)
t3=Thread(target=task,)
t1.start()
t2.start()
t3.start()
print(t1.is_alive()) #True
print(active_count()) #4
print(enumerate())