【Python智阐17】Python线程

线程概念

线程,有时被称为轻量进程(Lightweight Process,LWP),是程序执行流的最小单元。一个标准的线程由线程ID,当前指令指针(PC),寄存器集合和堆栈组成。另外,线程是进程中的一个实体,是被系统独立调度和分派的基本单位,线程自己不拥有系统资源,只拥有一点儿在运行中必不可少的资源,但它可与同属一个进程的其它线程共享进程所拥有的全部资源。一个线程可以创建和撤消另一个线程,同一进程中的多个线程之间可以并发执行。由于线程之间的相互制约,致使线程在运行中呈现出间断性。线程也有就绪、阻塞和运行三种基本状态。就绪状态是指线程具备运行的所有条件,逻辑上可以运行,在等待处理机;运行状态是指线程占有处理机正在运行;阻塞状态是指线程在等待一个事件(如某个信号量),逻辑上不可执行。每一个程序都至少有一个线程,若程序只有一个线程,那就是程序本身。

线程是程序中一个单一的顺序控制流程。进程内有一个相对独立的、可调度的执行单元,是系统独立调度和分派CPU的基本单位指令运行时的程序的调度单位。在单个程序中同时运行多个线程完成不同的工作,称为多线程。

(摘自百度百科)

1、创建进程

Python的标准库提供了两个模块:_thread和threading,其中thread是一个低级模块,threading是一个高级模块,它对_thread进行了封装。一般情况下,我们都使用threading这个高级模块。

示例:

importthreading

num =

deftest(n):

globalnum

# current_thread():返回返回当前线程的实例

print("子线程(%s)开始"% (threading.current_thread().name))

foriinrange(10000000):

num = num + n

num = num - n

print("子线程(%s)结束"% (threading.current_thread().name))

if__name__ =="__main__":

# 任何一个进程会启动一个线程,称为主线程

# 主线程可以启动新的子线程

print("主线程(%s)启动"% (threading.current_thread().name))

# 创建子线程,name 表示线程的名称

t1 = threading.Thread(target=test,name="线程1",args=(6,))

t2 = threading.Thread(target=test,name="线程2",args=(9,))

t1.start()

t2.start()

# 等待线程结束

t1.join()

t2.join()

print("num =%s"% (num))

print("主线程(%s)结束"% (threading.current_thread().name))

输出:

从以上代码执行结果可以看出:

最后的num=51,结果有异常,按照正常来说,应该为0。这是由于,在多线程中,所有变量都由所有线程共享。所以,任何一个变量都可以被任意一个线程修改,最终导致结果不正确。

线程之间共享数据最大的危险在于多个线程同时修改一个变量,导致最终的结果异常。

2、线程锁

为了解决刚刚的问题,我们需要使用线程锁来解决。

示例:

importthreading

#创建锁对象

lock = threading.Lock()

num =

deftest(n):

globalnum

foriinrange(100000):

# 上锁

lock.acquire()

try:

num = num + n

num = num - n

finally:

# 修改完一定要释放锁

lock.release()

if__name__ =="__main__":

t1 = threading.Thread(target=test,name="线程1",args=(6,))

t2 = threading.Thread(target=test,name="线程2",args=(9,))

t1.start()

t2.start()

t1.join()

t2.join()

print("num =%s"% (num))

输出:

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20181105G1P23N00?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。

扫码关注云+社区

领取腾讯云代金券