线程概念
线程,有时被称为轻量进程(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))
输出:
领取专属 10元无门槛券
私享最新 技术干货