python 全栈开发，Day41(线程概念,线程的特色,进程和线程的关系,线程和python 理论知识,线程的建立)

时间 2019-11-24

标签 python 开发 day41 day 线程概念特色进程关系理论知识建立栏目 Python 繁體版

原文原文链接

昨日内容回顾

队列
    队列 ： 先进先出、数据进程安全
    队列实现方式: 管道 + 锁
    生产者消费者模型 ： 解决数据供需不平衡
管道
    双向通讯 数据进程不安全
    EOFError：
        管道是由操做系统进行引用计数的，
        必须在全部进程中关闭管道后才能生成EOFError异常
数据共享（不经常使用）
    Manager
    list dict 数据进程不安全的
进程池
    存放进程的容器
    在进程建立之初，建立固定个数的进程
    会被多个任务循环利用
    节省了进程建立和销毁的时间开销
    下降了操做系统调度进程的压力
信号量和进程池的区别
    信号量 n个任务开启n个进程，
          但同一时间只能有固定个数的进程在执行
          进程在等待被执行
    进程池 n个任务开启固定个数的进程
          所以同一时间只能有固定个数的进程在执行
          任务在等待被执行

队列是内置锁的，因此别的应用调用它，是安全的。
凡是涉及到手动加锁的，都是不安全的。经常使用的通常都是消息中间件html

没有返回值的状况python

close和join成对使用linux

import time
from multiprocessing import Pool

def wahaha(i):
    time.sleep(1)
    print('*'*i)

if __name__ == '__main__':
    p = Pool(5) #建议的数量是CPU核数+1
    for i in range(5):
        p.apply_async(func=wahaha,args=(i,))
    p.close()  # 不能再提交新的任务
    p.join()  # 等待池中的任务都执行完

执行输出：程序员

*
**
***
****web

有返回值的状况算法

import time
from multiprocessing import Pool

def wahaha(i):
    time.sleep(1)
    return '*'*i

if __name__ == '__main__':
    p = Pool(5) #建议的数量是CPU核数+1
    res_1 = []
    for i in range(5):
        res = p.apply_async(func=wahaha,args=(i,))
        res_1.append(res)
    for i in res_1:print(i.get())

执行输出：编程

*
**
***
****小程序

总结：windows

主进程默认等待子进程结束 —— 守护进程
普通的进程：根据你调用的函数执行结束它就结束了
进程池里的进程
　　没有返回值：
　　　　在提交任务以后：
　　　　p.close() 不能再提交新的任务
　　　　p.join() 等待池中的任务都执行完
　　有返回值的时候：
　　　　在提交任务以后：
　　　　for i in res_l:print(i.get())安全

第二种写法：使用map

它不能获取返回值，参数必须是一个可迭代对象

import time
from multiprocessing import Pool

def wahaha(i):
    time.sleep(1)
    print('*'*i)

if __name__ == '__main__':
    p = Pool(5) #建议的数量是CPU核数+1
    p.map(func=wahaha,iterable=range(5))  # iterable接收一个可迭代对象

执行输出：

**
*
***
****

若是不须要返回值得，使用map便可

回调函数
　　回调函数在何时执行
　　　　子进程的任务执行完毕以后当即触发
　　回调函数的参数
　　　　子进程的返回值
　　回调函数是由谁执行的
　　　　主进程执行的
　　在哪儿用？
　　　　爬虫：
　　　　　　若是要爬取多个格式相同的网页
　　　　　　真正影响程序效率的是网络的延迟
　　　　　　计算分析处理网页的时间是很快的

若是主进程要处理好久，那么就不适合用回调函数

当你不肯定，到底有没有回调函数快？测试一下就知道了。
先不用回调函数，打印执行时间
再用回调函数，打印执行时间，对比一下，就知道了。

操做系统线程理论

线程概念的引入背景

进程

　　以前咱们已经了解了操做系统中进程的概念，程序并不能单独运行，只有将程序装载到内存中，系统为它分配资源才能运行，而这种执行的程序就称之为进程。程序和进程的区别就在于：程序是指令的集合，它是进程运行的静态描述文本；进程是程序的一次执行活动，属于动态概念。在多道编程中，咱们容许多个程序同时加载到内存中，在操做系统的调度下，能够实现并发地执行。这是这样的设计，大大提升了CPU的利用率。进程的出现让每一个用户感受到本身独享CPU，所以，进程就是为了在CPU上实现多道编程而提出的。

有了进程为何要有线程

　　进程有不少优势，它提供了多道编程，让咱们感受咱们每一个人都拥有本身的CPU和其余资源，能够提升计算机的利用率。不少人就不理解了，既然进程这么优秀，为何还要线程呢？其实，仔细观察就会发现进程仍是有不少缺陷的，主要体如今两点上：

进程只能在一个时间干一件事，若是想同时干两件事或多件事，进程就无能为力了。
进程在执行的过程当中若是阻塞，例如等待输入，整个进程就会挂起，即便进程中有些工做不依赖于输入的数据，也将没法执行。

　　若是这两个缺点理解比较困难的话，举个现实的例子也许你就清楚了：若是把咱们上课的过程当作一个进程的话，那么咱们要作的是耳朵听老师讲课，手上还要记笔记，脑子还要思考问题，这样才能高效的完成听课的任务。而若是只提供进程这个机制的话，上面这三件事将不能同时执行，同一时间只能作一件事，听的时候就不能记笔记，也不能用脑子思考，这是其一；若是老师在黑板上写演算过程，咱们开始记笔记，而老师忽然有一步推不下去了，阻塞住了，他在那边思考着，而咱们呢，也不能干其余事，即便你想趁此时思考一下刚才没听懂的一个问题都不行，这是其二。

　　如今你应该明白了进程的缺陷了，而解决的办法很简单，咱们彻底可让听、写、思三个独立的过程，并行起来，这样很明显能够提升听课的效率。而实际的操做系统中，也一样引入了这种相似的机制——线程。

线程的出现

　　60年代，在OS中能拥有资源和独立运行的基本单位是进程，然而随着计算机技术的发展，进程出现了不少弊端，一是因为进程是资源拥有者，建立、撤消与切换存在较大的时空开销，所以须要引入 轻型进程；二是因为对称多处理机（SMP）出现， 能够知足多个运行单位，而多个进程并行开销过大。

　　所以在80年代，出现了 能独立运行的基本单位——线程（Threads）。

　　注意：进程是资源分配的最小单位,线程是CPU调度的最小单位.

　　　　　每个进程中至少有一个线程。　

操做系统是管理进程的，每一个进程是资源隔离的。在一个操做系统中，同一时间，能够有多个任务。

多个任务之间的内存必须隔离开。好比使用qq的时候还能使用微信。并发要求日益增长，好比聊天的时候，能够开多个窗口，还能够看电影，听歌...

开启一个子进程的开销，是很大的。操做系统在进程之间的切换，时间开销也很大。

进程之间的通讯：

数据共享：时间开销
若是多个子进程之间的数据共享量过多的时候，
就不该该将这些数据隔离开

一个进程 —— 实现不了并发
你既不但愿数据隔离，还要实现并发的效果。那么就应该使用线程

线程是轻量级的进程
线程的建立和销毁所须要的时间开销都很是小
线程直接使用进程的内存
线程不能独立存在，要依赖于进程

进程和线程的关系

　　线程与进程的区别能够概括为如下4点：

　　1）地址空间和其它资源（如打开文件）：进程间相互独立，同一进程的各线程间共享。某进程内的线程在其它进程不可见。

　　2）通讯：进程间通讯 IPC，线程间能够直接读写进程数据段（如全局变量）来进行通讯——须要进程同步和互斥手段的辅助，以保证数据的一致性。

　　3）调度和切换：线程上下文切换比进程上下文切换要快得多。

　　4）在多线程操做系统中，进程不是一个可执行的实体。

　　 *经过漫画了解线程进城

print(123)

执行输出：123

真正执行代码的是线程
程序启动是一个进程。

使用线程执行代码，接受CPU调度。
线程的时间开销小于进程时间开销

线程的特色

　　在多线程的操做系统中，一般是在一个进程中包括多个线程，每一个线程都是做为利用CPU的基本单位，是花费最小开销的实体。线程具备如下属性。

　　1）轻型实体

　　线程中的实体基本上不拥有系统资源，只是有一点必不可少的、能保证独立运行的资源。

　　线程的实体包括程序、数据和TCB。线程是动态概念，它的动态特性由线程控制块TCB（Thread Control Block）描述。

TCB包括如下信息：
（1）线程状态。
（2）当线程不运行时，被保存的现场资源。
（3）一组执行堆栈。
（4）存放每一个线程的局部变量主存区。
（5）访问同一个进程中的主存和其它资源。
用于指示被执行指令序列的程序计数器、保留局部变量、少数状态参数和返回地址等的一组寄存器和堆栈。

TCB包括如下信息

2）独立调度和分派的基本单位。

　　在多线程OS中，线程是能独立运行的基本单位，于是也是独立调度和分派的基本单位。因为线程很“轻”，故线程的切换很是迅速且开销小（在同一进程中的）。

　　3）共享进程资源。

　　线程在同一进程中的各个线程，均可以共享该进程所拥有的资源，这首先表如今：全部线程都具备相同的进程id，这意味着，线程能够访问该进程的每个内存资源；此外，还能够访问进程所拥有的已打开文件、定时器、信号量机构等。因为同一个进程内的线程共享内存和文件，因此线程之间互相通讯没必要调用内核。

　　4 ）可并发执行。

　　在一个进程中的多个线程之间，能够并发执行，甚至容许在一个进程中全部线程都能并发执行；一样，不一样进程中的线程也能并发执行，充分利用和发挥了处理机与外围设备并行工做的能力。

使用线程的实际场景

　　开启一个字处理软件进程，该进程确定须要办不止一件事情，好比监听键盘输入，处理文字，定时自动将文字保存到硬盘，这三个任务操做的都是同一块数据，于是不能用多进程。只能在一个进程里并发地开启三个线程,若是是单线程，那就只能是，键盘输入时，不能处理文字和自动保存，自动保存时又不能输入和处理文字。

内存中的线程

　　多个线程共享同一个进程的地址空间中的资源，是对一台计算机上多个进程的模拟，有时也称线程为轻量级的进程。

　　而对一台计算机上多个进程，则共享物理内存、磁盘、打印机等其余物理资源。多线程的运行也多进程的运行相似，是cpu在多个线程之间的快速切换。

　　不一样的进程之间是充满敌意的，彼此是抢占、竞争cpu的关系，若是迅雷会和QQ抢资源。而同一个进程是由一个程序员的程序建立，因此同一进程内的线程是合做关系，一个线程能够访问另一个线程的内存地址，你们都是共享的，一个线程干死了另一个线程的内存，那纯属程序员脑子有问题。

　　相似于进程，每一个线程也有本身的堆栈，不一样于进程，线程库没法利用时钟中断强制线程让出CPU，能够调用thread_yield运行线程自动放弃cpu，让另一个线程运行。

　　线程一般是有益的，可是带来了不小程序设计难度，线程的问题是：

　　1. 父进程有多个线程，那么开启的子线程是否须要一样多的线程

　　2. 在同一个进程中，若是一个线程关闭了文件，而另一个线程正准备往该文件内写内容呢？

　　所以，在多线程的代码中，须要更多的心思来设计程序的逻辑、保护程序的数据。

线程是轻量级的进程
线程的建立和销毁所须要的时间开销都很是小
线程直接使用进程的内存
线程不能独立存在，要依赖于进程

进程 —— 资源分配的最小单位
线程 —— CPU调度的最小单位
轻型进程：建立、销毁、切换开销比进程小
数据不隔离
能够并发
依赖进程
每个进程里至少有一个线程
进程负责管理资源、线程负责执行代码

def func(exp):
    2+3*5-6  # 它不会影响全局变量
    return eval(exp)

python程序运行起来 —— 进程
进程 —— 管理整个程序的内存，
存储全局的变量 : 内置的函数全局的名字
线程 —— 执行代码

用户级线程和内核级线程（了解）

　　线程的实现能够分为两类：用户级线程(User-Level Thread)和内核线线程(Kernel-Level Thread)，后者又称为内核支持的线程或轻量级进程。在多线程操做系统中，各个系统的实现方式并不相同，在有的系统中实现了用户级线程，有的系统中实现了内核级线程。

用户级线程

　　内核的切换由用户态程序本身控制内核切换,不须要内核干涉，少了进出内核态的消耗，但不能很好的利用多核Cpu。

　　在用户空间模拟操做系统对进程的调度，来调用一个进程中的线程，每一个进程中都会有一个运行时系统，用来调度线程。此时当该进程获取cpu时，进程内再调度出一个线程去执行，同一时刻只有一个线程执行。

内核级线程

　　内核级线程:切换由内核控制，当线程进行切换的时候，由用户态转化为内核态。切换完毕要从内核态返回用户态；能够很好的利用smp，即利用多核cpu。windows线程就是这样的。

用户级与内核级线程的对比

内核支持线程是OS内核可感知的，而用户级线程是OS内核不可感知的。
用户级线程的建立、撤消和调度不须要OS内核的支持，是在语言（如Java）这一级处理的；而内核支持线程的建立、撤消和调度都需OS内核提供支持，并且与进程的建立、撤消和调度大致是相同的。
用户级线程执行系统调用指令时将致使其所属进程被中断，而内核支持线程执行系统调用指令时，只致使该线程被中断。
在只有用户级线程的系统内，CPU调度仍是以进程为单位，处于运行状态的进程中的多个线程，由用户程序控制线程的轮换运行；在有内核支持线程的系统内，CPU调度则以线程为单位，由OS的线程调度程序负责线程的调度。
用户级线程的程序实体是运行在用户态下的程序，而内核支持线程的程序实体则是能够运行在任何状态下的程序。

用户级线程和内核级线程的区别

优势：当有多个处理机时，一个进程的多个线程能够同时执行。
缺点：由内核进行调度。

内核线程的优缺点

优势：
线程的调度不须要内核直接参与，控制简单。
能够在不支持线程的操做系统中实现。
建立和销毁线程、线程切换代价等线程管理的代价比内核线程少得多。
容许每一个进程定制本身的调度算法，线程管理比较灵活。
线程可以利用的表空间和堆栈空间比内核级线程多。
同一进程中只能同时有一个线程在运行，若是有一个线程使用了系统调用而阻塞，那么整个进程都会被挂起。另外，页面失效也会产生一样的问题。
缺点：
资源调度按照进程进行，多个处理机下，同一个进程中的线程只能在同一个处理机下分时复用

用户级线程的优缺点

混合实现

　　用户级与内核级的多路复用，内核同一调度内核线程，每一个内核线程对应n个用户线程

linux操做系统的 NPTL

历史
在内核2.6之前的调度实体都是进程，内核并无真正支持线程。它是能过一个系统调用clone()来实现的，这个调用建立了一份调用进程的拷贝，跟fork()不一样的是,这份进程拷贝彻底共享了调用进程的地址空间。LinuxThread就是经过这个系统调用来提供线程在内核级的支持的(许多之前的线程实现都彻底是在用户态，内核根本不知道线程的存在)。很是不幸的是，这种方法有至关多的地方没有遵循POSIX标准，特别是在信号处理，调度，进程间通讯原语等方面。

很显然，为了改进LinuxThread必须获得内核的支持，而且须要重写线程库。为了实现这个需求，开始有两个相互竞争的项目：IBM启动的NGTP(Next Generation POSIX Threads)项目，以及Redhat公司的NPTL。在2003年的年中，IBM放弃了NGTP，也就是大约那时，Redhat发布了最初的NPTL。

NPTL最开始在redhat linux 9里发布，如今从RHEL3起内核2.6起都支持NPTL，而且彻底成了GNU C库的一部分。

 

设计
NPTL使用了跟LinuxThread相同的办法，在内核里面线程仍然被看成是一个进程，而且仍然使用了clone()系统调用(在NPTL库里调用)。可是，NPTL须要内核级的特殊支持来实现，好比须要挂起而后再唤醒线程的线程同步原语futex.

NPTL也是一个1*1的线程库，就是说，当你使用pthread_create()调用建立一个线程后，在内核里就相应建立了一个调度实体，在linux里就是一个新进程，这个方法最大可能的简化了线程的实现。

除NPTL的1*1模型外还有一个m*n模型，一般这种模型的用户线程数会比内核的调度实体多。在这种实现里，线程库自己必须去处理可能存在的调度，这样在线程库内部的上下文切换一般都会至关的快，由于它避免了系统调用转到内核态。然而这种模型增长了线程实现的复杂性,并可能出现诸如优先级反转的问题，此外，用户态的调度如何跟内核态的调度进行协调也是很难让人满意。

介绍

线程和python

理论知识

全局解释器锁GIL

　　Python代码的执行由Python虚拟机(也叫解释器主循环)来控制。Python在设计之初就考虑到要在主循环中，同时只有一个线程在执行。虽然 Python 解释器中能够“运行”多个线程，但在任意时刻只有一个线程在解释器中运行。
　　对Python虚拟机的访问由全局解释器锁(GIL)来控制，正是这个锁能保证同一时刻只有一个线程在运行。

　　在多线程环境中，Python 虚拟机按如下方式执行：

　　a、设置 GIL；

　　b、切换到一个线程去运行；

　　c、运行指定数量的字节码指令或者线程主动让出控制(能够调用 time.sleep(0))；

　　d、把线程设置为睡眠状态；

　　e、解锁 GIL；

　　d、再次重复以上全部步骤。
　　在调用外部代码(如 C/C++扩展函数)的时候，GIL将会被锁定，直到这个函数结束为止(因为在这期间没有Python的字节码被运行，因此不会作线程切换)编写扩展的程序员能够主动解锁GIL。

python线程模块的选择

　　Python提供了几个用于多线程编程的模块，包括thread、threading和Queue等。thread和threading模块容许程序员建立和管理线程。thread模块提供了基本的线程和锁的支持，threading提供了更高级别、功能更强的线程管理的功能。Queue模块容许用户建立一个能够用于多个线程之间共享数据的队列数据结构。
　　避免使用thread模块，由于更高级别的threading模块更为先进，对线程的支持更为完善，并且使用thread模块里的属性有可能会与threading出现冲突；其次低级别的thread模块的同步原语不多(实际上只有一个)，而threading模块则有不少；再者，thread模块中当主线程结束时，全部的线程都会被强制结束掉，没有警告也不会有正常的清除工做，至少threading模块能确保重要的子线程退出后进程才退出。

　　thread模块不支持守护线程，当主线程退出时，全部的子线程不论它们是否还在工做，都会被强行退出。而threading模块支持守护线程，守护线程通常是一个等待客户请求的服务器，若是没有客户提出请求它就在那等着，若是设定一个线程为守护线程，就表示这个线程是不重要的，在进程退出的时候，不用等待这个线程退出。

threading模块

multiprocess模块的彻底模仿了threading模块的接口，两者在使用层面，有很大的类似性，于是再也不详细介绍（官方连接）

线程的建立Threading.Thread类

线程的建立

from threading import Thread
import time
def sayhi(name):
    time.sleep(2)
    print('%s say hello' %name)

if __name__ == '__main__':
    t=Thread(target=sayhi,args=('egon',))
    t.start()
    print('主线程')

建立线程的方式1

from threading import Thread
import time
class Sayhi(Thread):
    def __init__(self,name):
        super().__init__()
        self.name=name
    def run(self):
        time.sleep(2)
        print('%s say hello' % self.name)


if __name__ == '__main__':
    t = Sayhi('egon')
    t.start()
    print('主线程')

建立线程的方式2

多线程与多进程

from threading import Thread
from multiprocessing import Process
import os

def work():
    print('hello',os.getpid())

if __name__ == '__main__':
    #part1:在主进程下开启多个线程,每一个线程都跟主进程的pid同样
    t1=Thread(target=work)
    t2=Thread(target=work)
    t1.start()
    t2.start()
    print('主线程/主进程pid',os.getpid())

    #part2:开多个进程,每一个进程都有不一样的pid
    p1=Process(target=work)
    p2=Process(target=work)
    p1.start()
    p2.start()
    print('主线程/主进程pid',os.getpid())

pid的比较

from threading import Thread
from multiprocessing import Process
import os

def work():
    print('hello')

if __name__ == '__main__':
    #在主进程下开启线程
    t=Thread(target=work)
    t.start()
    print('主线程/主进程')
    '''
    打印结果:
    hello
    主线程/主进程
    '''

    #在主进程下开启子进程
    t=Process(target=work)
    t.start()
    print('主线程/主进程')
    '''
    打印结果:
    主线程/主进程
    hello
    '''

开启效率的较量

from  threading import Thread
from multiprocessing import Process
import os
def work():
    global n
    n=0

if __name__ == '__main__':
    # n=100
    # p=Process(target=work)
    # p.start()
    # p.join()
    # print('主',n) #毫无疑问子进程p已经将本身的全局的n改为了0,但改的仅仅是它本身的,查看父进程的n仍然为100


    n=1
    t=Thread(target=work)
    t.start()
    t.join()
    print('主',n) #查看结果为0,由于同一进程内的线程之间共享进程内的数据
同一进程内的线程共享该进程的数据？

内存数据的共享问题

练习：多线程实现socket

#_*_coding:utf-8_*_
#!/usr/bin/env python
import multiprocessing
import threading

import socket
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.bind(('127.0.0.1',8080))
s.listen(5)

def action(conn):
    while True:
        data=conn.recv(1024)
        print(data)
        conn.send(data.upper())

if __name__ == '__main__':

    while True:
        conn,addr=s.accept()


        p=threading.Thread(target=action,args=(conn,))
        p.start()

server

#_*_coding:utf-8_*_
#!/usr/bin/env python


import socket

s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.connect(('127.0.0.1',8080))

while True:
    msg=input('>>: ').strip()
    if not msg:continue

    s.send(msg.encode('utf-8'))
    data=s.recv(1024)
    print(data)

client

Thread类的其余方法

Thread实例对象的方法
  # isAlive(): 返回线程是否活动的。
  # getName(): 返回线程名。
  # setName(): 设置线程名。

threading模块提供的一些方法：
  # threading.currentThread(): 返回当前的线程变量。
  # threading.enumerate(): 返回一个包含正在运行的线程的list。正在运行指线程启动后、结束前，不包括启动前和终止后的线程。
  # threading.activeCount(): 返回正在运行的线程数量，与len(threading.enumerate())有相同的结果。

from threading import Thread
import threading
from multiprocessing import Process
import os

def work():
    import time
    time.sleep(3)
    print(threading.current_thread().getName())


if __name__ == '__main__':
    #在主进程下开启线程
    t=Thread(target=work)
    t.start()

    print(threading.current_thread().getName())
    print(threading.current_thread()) #主线程
    print(threading.enumerate()) #连同主线程在内有两个运行的线程
    print(threading.active_count())
    print('主线程/主进程')

    '''
    打印结果:
    MainThread
    <_MainThread(MainThread, started 140735268892672)>
    [<_MainThread(MainThread, started 140735268892672)>, <Thread(Thread-1, started 123145307557888)>]
    主线程/主进程
    Thread-1
    '''

代码示例

from threading import Thread
import time
def sayhi(name):
    time.sleep(2)
    print('%s say hello' %name)

if __name__ == '__main__':
    t=Thread(target=sayhi,args=('egon',))
    t.start()
    t.join()
    print('主线程')
    print(t.is_alive())
    '''
    egon say hello
    主线程
    False
    '''

join方法

守护线程

不管是进程仍是线程，都遵循：守护xx会等待主xx运行完毕后被销毁。须要强调的是：运行完毕并不是终止运行

#1.对主进程来讲，运行完毕指的是主进程代码运行完毕
#2.对主线程来讲，运行完毕指的是主线程所在的进程内全部非守护线程通通运行完毕，主线程才算运行完毕

#1 主进程在其代码结束后就已经算运行完毕了（守护进程在此时就被回收）,而后主进程会一直等非守护的子进程都运行完毕后回收子进程的资源(不然会产生僵尸进程)，才会结束，
#2 主线程在其余非守护线程运行完毕后才算运行完毕（守护线程在此时就被回收）。由于主线程的结束意味着进程的结束，进程总体的资源都将被回收，而进程必须保证非守护线程都运行完毕后才能结束。

详细解释

from threading import Thread
import time
def sayhi(name):
    time.sleep(2)
    print('%s say hello' %name)

if __name__ == '__main__':
    t=Thread(target=sayhi,args=('egon',))
    t.setDaemon(True) #必须在t.start()以前设置
    t.start()

    print('主线程')
    print(t.is_alive())
    '''
    主线程
    True
    '''

守护线程例1

from threading import Thread
import time
def foo():
    print(123)
    time.sleep(1)
    print("end123")

def bar():
    print(456)
    time.sleep(3)
    print("end456")


t1=Thread(target=foo)
t2=Thread(target=bar)

t1.daemon=True
t1.start()
t2.start()
print("main-------")

守护线程例2

简单例子：

from threading import Thread
def func(i):
    print('*'*i)
Thread(target=func,args=(1,)).start()

执行输出：*

开5个线程

from threading import Thread
def func(i):
    print('*'*i)

for i in range(5):
    Thread(target=func,args=(i,)).start()

执行输出：

*
**
***
****

作效率测试，进程和线程，谁更快

import time
from threading import Thread
from multiprocessing import Process
def func(i):
    print('*'*i)

if __name__ == '__main__':
    start = time.time()
    for i in range(5):
        Thread(target=func,args=(i,)).start()
    print('线程',time.time()-start)

    start = time.time()
    for i in range(5):
        Process(target=func,args=(i,)).start()
    print('进程',time.time()-start)

执行输出：

*
**
***
****
线程 0.0020182132720947266
进程 0.0661768913269043

*
**
***
****

从结果中，能够看出：线程比进程更快。

使用join方法等待全部线程/进程执行完毕，再测试

import time
from threading import Thread
from multiprocessing import Process
def func(i):
    print('*'*i)

if __name__ == '__main__':
    start = time.time()
    thread_lst = []
    for i in range(5):
        t = Thread(target=func,args=(i,))
        t.start()
        thread_lst.append(t)
    for t in thread_lst:t.join()  # 等待全部线程执行完毕
    print('线程',time.time()-start)

    start = time.time()
    process_lst = []
    for i in range(5):
        p = Process(target=func,args=(i,))
        p.start()
        process_lst.append(p)
    for p in process_lst:p.join()
    print('进程',time.time()-start)

执行输出：

*
**
***
****
线程 0.0030286312103271484

*
**
***
****
进程 0.16040682792663574

仍是线程最快。

线程并发效果：
全部方法睡1秒

import time
from threading import Thread

def func(i):
    time.sleep(1)
    print('*'*i)

if __name__ == '__main__':
    start = time.time()
    thread_lst = []
    for i in range(10):
        t = Thread(target=func,args=(i,))
        t.start()
        thread_lst.append(t)
    for t in thread_lst:t.join()
    print(time.time()-start)

执行输出

**
*****
********
******
****
*******
***
*********
1.003647804260254

线程执行，是异步的。
操做系统控制了线程的执行。线程执行，顺序是乱的。
并发执行，没有顺序。从结果中，就能够看出。

打印线程号

import os
import time
from threading import Thread

def func(i):
    print('--->子线程',os.getpid())
    time.sleep(1)
    print('*'*i)

if __name__ == '__main__':
    print('主进程',os.getpid())
    start = time.time()
    thread_lst = []
    for i in range(10):
        t = Thread(target=func,args=(i,))
        t.start()
        thread_lst.append(t)
    for t in thread_lst:t.join()
    print(time.time()-start)

执行输出：

主进程 20120
--->子线程 20120
--->子线程 20120
--->子线程 20120
--->子线程 20120
--->子线程 20120
--->子线程 20120
--->子线程 20120
--->子线程 20120
--->子线程 20120
--->子线程 20120

****
**
*
***
*****
*********
*******
******
********
1.0029516220092773

显示线程名以及线程标识号

import os
import time
from threading import Thread

def func(i):
    print('--->子线程',os.getpid())
    time.sleep(1)
    print('*'*i)

if __name__ == '__main__':
    print('主进程',os.getpid())
    start = time.time()
    thread_lst = []
    for i in range(10):
        t = Thread(target=func,args=(i,))
        t.start()
        #Thread.name 获取和设置线程的名称
        #Thread.ident 获取线程的标识符
        print('-->',t.name,t.ident)
        thread_lst.append(t)
    for t in thread_lst:t.join()  # 等待全部线程结束
    print(time.time()-start)

执行输出：

主进程 20260
--->子线程 20260
--> Thread-1 21460
--->子线程 20260
--> Thread-2 20580
--->子线程 20260
--> Thread-3 21456
--->子线程 20260
--> Thread-4 19076
--->子线程 20260
--> Thread-5 5988
--->子线程 20260
--> Thread-6 17780
--->子线程 20260
--> Thread-7 20572
--->子线程 20260
--> Thread-8 20604
--->子线程 20260
--> Thread-9 20308
--->子线程 20260
--> Thread-10 19312
*

**
****
***
********
******
*******
*****
*********
1.0048184394836426

能够看出

同一个进程下的多个线程进程号相同 : 线程号不一样

为何进程执行须要if __name__ == '__main__' :

而线程不须要呢？看下图

停不下来了，主因是start()

加了if __name__ = '__main__' ,不会出现循环导入问题

进程执行时，至关于把当前文件给import了一次，那么全部代码会加载一次。

而线程执行时，是直接从进程中获取值。

线程引用主进程的变量，修改数据

from threading import Thread

n = 100
def manage():
    global n
    n = 0  # 修改全局变量

t = Thread(target=manage)
t.start()
t.join()
print('-->',n)

执行输出：

--> 0

结论：

线程和进程的区别：

1. 效率问题 : 线程快进程慢
2. 同一个进程下的多个线程进程号相同 : 线程号不一样
3. if __name__ == '__main__' : 开启进程必须有这句话可是开启线程不须要
这种现象只在windows操做系统上才出现
4. 数据的共享问题：在进程之间数据隔离，在线程之间数据共享

线程和进程是一把双刃剑，用好了，能够提示效率。不然程序崩塌。

全局解释器锁GIL

GIL问题，截止到目前为止，尚未解决。
解释行语言，都存在这个问题

GIL,主要是锁线程。不是锁进程。

关于GIL的多线程之争

参考文章

http://url.cn/5ihcAum

python运行，相对于编译型语言，好比c语言，执行比较慢

2者的运行区别：

python代码 --> 字节码--> 机器码
c语言字节码 --> 机器码

python 多线程同时，只能调用一个CPU。而C语言，能直接调用多个CPU。

因此在高计算性场景中，C比python更胜一筹

python更适合高IO型的程序：好比web网站，爬虫...

python的程序就不能充分的利用CPU了呢？？？使用多进程就能够解决。
多进程 —— 开启和销毁的时候慢，操做系统切换的时候也慢

可是切换的影响很是小

GIL —— 全局解释器锁
锁线程：在计算的时候同一时刻只能有一个线程访问CPU
线程锁限制了你对CPU的使用，可是不影响web类或者爬虫类代码的效率
咱们能够经过启动多进程的形式来弥补这个问题

import time
from threading import Thread
def func1():
    while True:
        time.sleep(1)
        print('子线程')

t = Thread(target=func1)
t.start()
print('主线程')

执行输出：

主线程
子线程
子线程

...

一直在输出子线程。为何呢？

主线程，会等待子线程结束

守护线程：

import time
from threading import Thread
def func1():       # 守护线程
    while True:
        time.sleep(1)
        print('子线程')

t = Thread(target=func1)
t.setDaemon(True)
t.start()
print('主线程')

执行输出：

主线程

发送瞬间就执行完毕了。

为啥子线程，没输出呢？因主线程执行完毕，子线程随之关闭。

在来一个例子

import time
from threading import Thread
def func1():       # 守护线程
    while True:
        time.sleep(1)
        print('子线程')

def func2():
    time.sleep(5)
    print('子线程2')

t = Thread(target=func1)
t2 = Thread(target=func2)
t.setDaemon(True)  # 设置守护线程
t.start()
t2.start()
print('主线程')

执行输出：

主线程
子线程
子线程
子线程
子线程
子线程2

结论：

主进程的守护进程是在主进程的代码结束，守护进程就结束了
主线程的守护线程会在非守护线程的全部线程执行完毕以后才结束

在同一个进程里面的多个线程，会受到GIL锁的限制。
多个进程之间，不会有GIL
一个CPU，同时只有一个线程执行

cpu同一时刻只能执行一个进程？答案是的
cpu同一时刻只能执行一个进程中的某一个线程
以前写的python代码，都是属于单线程的程序

明日默写：

import time
from threading import Thread
def func1():       # 守护线程
    while True:
        time.sleep(1)
        print('子线程')

def func2():
    time.sleep(5)
    print('子线程2')

t = Thread(target=func1)
t2 = Thread(target=func2)
t.setDaemon(True)
t.start()
t2.start()
print('主线程')

python 全栈开发，Day41(线程概念,线程的特色,进程和线程的关系,线程和python 理论知识,线程的建立)

昨日内容回顾

操做系统线程理论

线程概念的引入背景

进程

有了进程为何要有线程

线程的出现

进程和线程的关系

线程的特色

使用线程的实际场景

内存中的线程

用户级线程和内核级线程（了解）

用户级线程

内核级线程

用户级与内核级线程的对比

混合实现

linux操做系统的 NPTL

线程和python

理论知识

全局解释器锁GIL

python线程模块的选择

threading模块

线程的建立Threading.Thread类

线程的建立

多线程与多进程

练习 ：多线程实现socket

Thread类的其余方法

守护线程

练习：多线程实现socket