python_day27__线程和进程_threading模块_

时间:2022-12-31 13:01:02

#Author:'haijing'
#date:2018/11/18

# 只有操作系统(os)才可以去调动cpu、硬盘等
# 以前写的每一个.py文件就是一个进程,这个进程中只有一个主线程
#比如qq就是一个进程,qq这个进程中有很多的功能,
#线程是可以资源共享的(共享cpu的资源),但是进程是不可以资源共享的,比如360收不到qq消息
#能让操作系统工作起来的最小单位就是线程
#自己写的一个py文件中的一堆指令,就是一个线程。这堆指令被执行的时候,就调度了cpu
#或一个指令集就是一个线程
#只有一个cpu的话去执行多个程序,方法是以很快的速度去切换,用户是感受不到这个速度的,但是切换也是会有耽误时间的
#I/O密集型任务或函数(多用多线程,因为有阻塞的状态)
#计算密集型任务或函数(少用多线程,因为就是去计算,而且切换也是会有时间损耗)

#以下整体就是一个进程,这个进程包括了3个线程:一个主进程、两个子进程
#进程是线程资源的集合
#进程和线程执行速度是一样的,执行线程和执行进程是在执行同样的东西
import time
import threading #多线程模块

#I/O密集型 适合用多线程 因为有阻塞,比如time.sleep(1)就是一个阻塞
# begin = time.time() #主线程
# def foo(a):
# print('foo:%s' %a)
# time.sleep(1) #睡1秒钟 相当于I/O阻塞,那么cpu切换到别的子线程中去执行,如果都阻塞住,那么cpu就休息了
# print('end foo')
#
# def bar(a):
# print('bar:%s' %a)
# time.sleep(2) #睡1秒钟 不占用cpu,此时cpu就会执行别的子线程或者主线程
# print('end bar')
#
# t1 = threading.Thread(target=foo,args=(1,)) #创建了一个子线程对象t1,相当于foo(1) *****
# t1.start() #子线程执行 *****
# t2 = threading.Thread(target=bar,args=(2,)) #创建了一个子线程对象t2,相当于bar(2) *****
# t2.start() #子线程执行 *****
#
# end = time.time() #主线程
# print(end-begin) #打印程序执行的时间 #主线程
#子线程和主线程是并驾齐驱的,同时执行 谁快谁慢 是抢占式的
#至于同时显示(主线程和子线程)程序执行的结果,是因为切换的速度快,也就是说,在一个时刻,也是只有一条代码在执行,即使是有子线程和主线程,只不过在某条程序有阻塞的时候会去执行别的子线程

#而子线程中的其余的程序也是一起执行的,线程之间可以数据共享,进程不可以(但是可以通过队列等进行通信)

#Cpython中有一个解释器锁GIL,表示在同一时刻,只能有一个线程,如果有多个线程,那么就会去竞争
#因为有了GIL,所以多核cpu也没用了
#GIL是不让一个进程中的多个线程同时跑,但是让多个进程同时跑,每个进程分配每个cpu即可

# foo(1)
# bar(2) #这样执行是串行执行代码
#并行是好几个cpu同时在工作

#阻塞:比如上次的程序中的等待客户端来连接服务端就是一个阻塞

#计算密集型 不适合用多线程 因为总是要执行完所有的计算过程的,而且计算过程肯定是没有阻塞的
# begin = time.time()
def add(n):
sum = 0
for i in range(n):
sum += i
print(sum)
# add(1000000)
# add(2000000)
#
# end = time.time()
# print(end-begin)

begin = time.time()
t3 = threading.Thread(target=add,args=(1000000,))
t3.start()
t4 = threading.Thread(target=add,args=(2000000,))
t4.start()

end = time.time()
print(end-begin)

# 结论:在python中
# if 任务是IO密集型的 可以用多线程
# if 任务是计算密集型的 改用c语言

#join:谁调用join,谁就阻塞住,如t1.join()表示如果t1没有执行完,其余的谁也不能去执行,其实就是串行,没有多大的意义
# for t in thread: #假如thread=[t1,t2]
# t.start()
# t.join() #不在for循环内时,这一句等价于t2.join()

#Daemon: t1.setDaemon(True)设置守护线程,只要是主线程结束了,那么t1子线程也立马结束,其余线程正常执行

print(threading.current_thread()) #打印当前执行的线程
print(threading.active_count()) #打印没有结束的线程

#注:Cpython是用c语言写的python解释器

python_day27__线程和进程_threading模块_
图 多进程解决Cpyton中的GIL问题

最近特别的想回家,不知道是为什么,刚刚三点的时候和我妹妹微信语音了大概三十多分钟,主要是给她说了一下这次期中考试的事情,别的顺带的问了一下,
知道我爸在干什么,我妈在干什么,就很知足了,最重要的是不想再让我爸妈那么的辛苦了;我知道最近家里在盖浴室,爸妈肯定都累坏了。

  我知道目前我还不是能够让我爸妈引以为豪的儿子,以后可能会慢慢标号的吧。
  现在在听beyond的大地,其中有一句评论:我离天空最高的一次,是你把我高高的举过了你的肩头。
                                    haijing in HZ
                                    2018.11.18 周末 傍晚 雨