title: python多线程
author: BbiHH
tags:

• Naoqi机器人
• ‘’
  categories:
• 多线程
• python
  date: 2019-08-10 10:33:00

---

(原创)

多线程

这里先了解一下进程与线程 :

进程（Process） : 进程是一个具有一定独立功能的程序在一个数据集上的一次动态执行的过程，是操作系统进行资源分配和调度的一个独立单位，是应用程序运行的载体。进程是一种抽象的概念，从来没有统一的标准定义。进程一般由程序，数据集合和进程控制块三部分组成。程序用于描述进程要完成的功能，是控制进程执行的指令集；数据集合是程序在执行时所需要的数据和工作区；程序控制块包含进程的描述信息和控制信息
是进程存在的唯一标志。
线程(Thread) :线程是操作系统能够进行运算调度的最小单位。它被包含在进程之中，是进程中的实际运作单位。一条线程指的是进程中一个单一顺序的控制流，一个进程中可以并发多个线程，每条线程并行执行不同的任务。

一个进程就类似于你写好的一个程序(可以理解为任务集),而你的程序就是通过其他更小的子任务完成. 而进程中的子任务就能分到线程中,由多个线程完成多个子任务. 两者都是抽象概念 , 进程与线程可以理解为父子关系 . 普通程序是传统的顺序执行 , 多线程程序可以把程序中的子任务放一起来跑,是一种并发式执行.

进行CPU分配是以线程为单位的，一个进程可能由多个线程组成，这时情况更加复杂，但简单地说，有如下关系：

• 总线程数<= CPU数量：并行运行

• 总线程数 > CPU数量：并发运行

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-VxUaeQMP-1594014342680)(/images/pasted-14.png)]
在单核CPU中,多线程在单cpu中其实也是顺序执行的，不过系统可以帮你切换那个执行而已,在线程转换的时候会占据一定的时间,时间比顺序执行还慢,但多线程能避免程序堵塞.

而在多核CPU中,大部分操作系统的任务调度是采用时间片轮转的抢占式调度方式，也就是说一个任务执行一小段时间后强制暂停去执行下一个任务，每个任务轮流执行。由于每个时间片的间隔很小(10ms),可以认为CPU在同时跑不同的任务(一心多用).

python多线程

多线程类似于同时执行多个不同程序，多线程运行有如下优点：

• 使用线程可以把占据长时间的程序中的任务放到后台去处理。
• 用户界面可以更加吸引人，这样比如用户点击了一个按钮去触发某些事件的处理，可以弹出一个进度条来显示处理的进度
• 程序的运行速度可能加快-
• 在一些等待的任务实现上如用户输入、文件读写和网络收发数据等，线程就比较有用了。在这种情况下我们可以释放一些珍贵的资源如内存占用等等。

线程在执行过程中与进程还是有区别的。每个独立的进程有一个程序运行的入口、顺序执行序列和程序的出口。但是线程不能够独立执行，必须依存在应用程序中，由 应用程序 提供多个线程执行控制。

每个线程都有他自己的一组CPU寄存器，称为线程的上下文，该上下文反映了线程上次运行该线程的CPU寄存器的状态。

指令指针和堆栈指针寄存器是线程上下文中两个最重要的寄存器，线程总是在进程得到上下文中运行的，这些地址都用于标志拥有线程的进程地址空间中的内存。

• 线程可以被抢占（中断）。
• 在其他线程正在运行时，线程可以暂时搁置（也称为睡眠） – 这就是线程的退让。

线程模块

Python通过两个标准库thread和threading提供对线程的支持。thread提供了低级别的、原始的线程以及一个简单的锁。

threading 模块提供的其他方法：

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

除了使用方法外，线程模块同样提供了Thread类来处理线程，Thread类提供了以下方法:

• run(): 用以表示线程活动的方法。

• start():启动线程活动。

• join([time]): 等待至线程中止。这阻塞调用线程直至线程的join() 方法被调用中止-正常退出或者抛出未处理的异常-或者是可选的超时发生。

• isAlive(): 返回线程是否活动的。

• getName(): 返回线程名。

• setName(): 设置线程名。

#!/usr/bin/python
    # -*- coding: UTF-8 -*-
 
    import thread
    import time
 
    # 为线程定义一个函数
    def print_time( threadName, delay):
       count = 0
       while count < 5:
          time.sleep(delay)
          count += 1
          print "%s: %s" % ( threadName, time.ctime(time.time()) )
 
    # 创建两个线程
    try:
       thread.start_new_thread( print_time, ("Thread-1", 2, ) )
       thread.start_new_thread( print_time, ("Thread-2", 4, ) )
       #thread.join()
       print "结束"
    except:
       print "Error: unable to start thread"
 
    while 1:
       pass