python学习笔记——多线程

进程&＃xff1a;

电脑同时运行有多个软件&＃xff0c;每一个运行的软件程序都是一个进程。

线程&＃xff1a;

每一个应用程序内&＃xff0c;有多段程序同时执行&＃xff0c;每一段程序就是一个线程。

Python3 线程中常用的两个模块为&＃xff1a;

• _thread
• threading(推荐使用)

thread 模块已被废弃。用户可以使用 threading 模块代替。所以&＃xff0c;在 Python3 中不能再使用"thread" 模块。为了兼容性&＃xff0c;Python3 将 thread 重命名为 "_thread"。

1._thread&＃xff08;新线程要做的事放进函数里&＃xff09;

# coding:utf-8
import _thread# 定义一个函数
def print_time(threadName):for i in range(100):print(threadName, &＃39;:&＃39;, i)&＃39;&＃39;&＃39;创建两个线程,并开启两个线程&＃39;&＃39;&＃39;
_thread.start_new_thread(print_time, ("Thread-1",))
_thread.start_new_thread(print_time, ("Thread---------2",))&＃39;&＃39;&＃39;上面开启的都是子线程&＃xff0c;这里是主线程,主线程要是结束&＃xff0c;子线程就停止了&＃39;&＃39;&＃39;
while 1:pass


结果&＃xff1a;

2.threading

2.1threading&＃xff08;新线程要做的事放进类的run方法里&＃xff09;

# coding:utf-8
import threadingclass myThread(threading.Thread):def __init__(self, threadName):threading.Thread.__init__(self)self.threadName &＃61; threadNamedef run(self):for i in range(100):print(self.threadName, &＃39;:&＃39;, i)
&＃39;&＃39;&＃39;创建两个线程,并开启两个线程&＃39;&＃39;&＃39;
m1 &＃61; myThread("Thread-1")
m2 &＃61; myThread("Thread-2")
m1.start()
m2.start()&＃39;&＃39;&＃39;threading这种方式。即使主线程先执行完&＃xff0c;程序也不会关闭&＃xff0c;需要等子线程执行完&＃39;&＃39;&＃39;

2.2threading&＃xff08;新线程要做的事放进函数里&＃xff09;

# coding:utf-8
import threading# 定义一个函数
def print_time(threadName):for i in range(100):print(threadName, &＃39;:&＃39;, i)&＃39;&＃39;&＃39;创建两个线程,并开启两个线程&＃39;&＃39;&＃39;
t1&＃61;threading.Thread(target&＃61;print_time,args&＃61;("Thread-1",))
t2&＃61;threading.Thread(target&＃61;print_time,args&＃61;("Thread-2", ))
t1.start()
t2.start()&＃39;&＃39;&＃39;threading这种方式。即使主线程先执行完&＃xff0c;程序也不会关闭&＃xff0c;需要等子线程执行完&＃39;&＃39;&＃39;

2.3守护线程&＃xff08;setDaemon(True)&＃xff09;

子线程设置成守护线程&＃xff0c;相当于把子线程设置成主线程的守卫&＃xff0c;小弟守卫老大的安全&＃xff0c;老大&＃xff08;主线程&＃xff09;结束了&＃xff0c;小弟&＃xff08;子线程&＃xff09;也就结束了 

# coding:utf-8
import threading# 为线程定义一个函数
def print_time(threadName):for i in range(100):print(threadName, &＃39;:&＃39;, i)&＃39;&＃39;&＃39;创建两个线程&＃39;&＃39;&＃39;
t1 &＃61; threading.Thread(target&＃61;print_time,args&＃61;("Thread-1",))
t2 &＃61; threading.Thread(target&＃61;print_time,args&＃61;("Thread-2", ))&＃39;&＃39;&＃39;设置守护线程后&＃xff0c;主线程结束时&＃xff0c;子线程也将立即结束&＃xff0c;不再执行。&＃39;&＃39;&＃39;
t1.setDaemon(True) #把子进程设置为守护线程&＃xff0c;必须在start()之前设置
t2.setDaemon(True) #把子进程设置为守护线程&＃xff0c;必须在start()之前设置&＃39;&＃39;&＃39;开启两个线程&＃39;&＃39;&＃39;
t1.start()
t2.start()


2.4主线程等待子线程结束&＃xff08;join()方法&＃xff09;

# coding:utf-8
import threading# 为线程定义一个函数
def print_time(threadName):for i in range(100):print(threadName, &＃39;:&＃39;, i)&＃39;&＃39;&＃39;创建两个线程&＃39;&＃39;&＃39;
t1 &＃61; threading.Thread(target&＃61;print_time,args&＃61;("Thread-1",))
t2 &＃61; threading.Thread(target&＃61;print_time,args&＃61;("Thread-2", ))&＃39;&＃39;&＃39;设置守护线程后&＃xff0c;主线程结束时&＃xff0c;子线程也将立即结束&＃xff0c;不再执行。&＃39;&＃39;&＃39;
# t1.setDaemon(True) #把子进程设置为守护线程&＃xff0c;必须在start()之前设置
# t2.setDaemon(True) #把子进程设置为守护线程&＃xff0c;必须在start()之前设置&＃39;&＃39;&＃39;开启两个线程&＃39;&＃39;&＃39;
t1.start()
t2.start()t1.join() # 将自己加入到主线程的级别&＃xff0c;执行结束&＃xff0c;整个程序才可结束
t2.join() # 将自己加入到主线程的级别&＃xff0c;执行结束&＃xff0c;整个程序才可结束


2.5多线程共享全局变量

使用 Thread 对象的 Lock 和 Rlock 可以实现简单的线程同步&＃xff0c;这两个对象都有 acquire 方法和 release 方法&＃xff0c;对于那些需要每次只允许一个线程操作的数据或代码&＃xff0c;可以将其操作放到 acquire 和 release 方法之间。

acquire 和 release之间的数据或代码&＃xff0c;同一时间&＃xff0c;只能同时被一个线程占用。

不使用线程锁

# coding:utf-8
from threading import Thread,Lock
import timecount &＃61; 0
#lock &＃61; Lock()#创建锁的锁的对象
def print_time(threadName):global countfor i in range(100):count &＃43;&＃61; 1time.sleep(0.01)#lock.acquire() # 获得使用权print(threadName, &＃39;:&＃39;, count)#lock.release()#释放使用权&＃39;&＃39;&＃39;创建两个线程&＃39;&＃39;&＃39;
t1 &＃61; Thread(target&＃61;print_time,args&＃61;("Thread-1",))
t2 &＃61; Thread(target&＃61;print_time,args&＃61;("Thread-2", ))
&＃39;&＃39;&＃39;开启两个线程&＃39;&＃39;&＃39;
t1.start()
t2.start()

结果&＃xff1a;(打印语句有可能两个线程都在用&＃xff0c;打印混乱)

使用线程锁

# coding:utf-8
from threading import Thread,Lock
import timecount &＃61; 0
lock &＃61; Lock()#创建锁的锁的对象
def print_time(threadName):global countfor i in range(100):count &＃43;&＃61; 1time.sleep(0.01)lock.acquire() # 获得使用权print(threadName, &＃39;:&＃39;, count)lock.release()#释放使用权&＃39;&＃39;&＃39;创建两个线程&＃39;&＃39;&＃39;
t1 &＃61; Thread(target&＃61;print_time,args&＃61;("Thread-1",))
t2 &＃61; Thread(target&＃61;print_time,args&＃61;("Thread-2", ))
&＃39;&＃39;&＃39;开启两个线程&＃39;&＃39;&＃39;
t1.start()
t2.start()

结果&＃xff1a;

&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

参考来源&＃xff1a;

https://www.runoob.com/python3/python3-multithreading.html

https://www.cnblogs.com/luyuze95/p/11289143.html