13.1 threading 模块

BC3BA70FAEE8FE851CA38B0C49F897CA.jpg

      简单演示该模块方法：

>>> import threading
>>> threading.stack_size()  # 查看当前线程栈大小
0
>>> threading.stack_size(64 * 1024) # 设置当前线程栈大小
0
>>> threading.active_count()  # 当前活动线程数量
2
>>> threading.current_thread()  # 当前线程对象
<_MainThread(MainThread, started 13100)>
>>> threading.enumerate()  # 当前活动线程对象列表
[<_MainThread(MainThread, started 13100)>, <Thread(SockThread, started daemon 10460)>]

13.2.1 Thread 对象中的方法

      Thread 类创建线程对象，调用其 start() 方法来启动，该方法自动调用该类对象的 run() 方法，此时该线程处于 alive 状态，直到 run() 方法运行结束。

2C59040A0A67981D2B7D841B6CD394E5.jpg

（1）join([timeout)) ：阻塞当前线程，等待被调线程结束或超时后再执行当前线程的后续代码。

import threading
import time

def func(x, y):
    for i in range(x, y):
        print(i, end = ' ')
    time.sleep(10)

t1 = threading.Thread(target = func, args = (15, 20))
t1.start()
t1.join(5)
t2 = threading.Thread(target = func, args = (5, 10))
t2.start()

（2）is_alive() ：测试线程是否处于运行状态。

import threading
import time

def func(x, y):
    for i in range(x, y):
        print(i, end = ' ')
    # time.sleep(10)

t1 = threading.Thread(target = func, args = (15, 20))
t1.start()
t1.join(5)
t2 = threading.Thread(target = func, args = (5, 10))
t2.start()
print('t1:', t1.is_alive())
print('t2:', t2.is_alive())

13.2.2 Thread 对象中的 daemon 属性

      当某子线程的 daemon 属性为 True 时，主线程运行结束时不对该子线程进行检查直接退出，同时所有 daemon 值为 True 的子线程将随主线程一切结束，不论是否完成。daemon 属性默认为 False，如需修改，必须在 start() 方法之前修改。

import threading
import time

class mythread(threading.Thread):
    def __init__(self, num, threadname):
        threading.Thread.__init__(self, name = threadname)
        self.num = num

    def run(self):
        time.sleep(self.num)
        print(self.num)


t1 = mythread(1, 't1')
t2 = mythread(5, 't2')
t2.daemon = True
print(t1.daemon)
print(t2.daemon)
t1.start()
t2.start()
        

      派生自 Thread 类的自定义线程类首先也是一个普通类，同时拥有线程类的 run()、start()、join()等方法。

import threading
import time

class myThread(threading.Thread):
    def __init__(self, threadName):
        threading.Thread.__init__(self)
        self.name = threadName

    def run(self):
        time.sleep(1)
        print('In run:', self.name)

    def output(self):               # 在线程类中定义普通方法
        print('In output:', self.name)

t = myThread('test')
t.start()
t.output()                          # 调用普通方法
time.sleep(2)
print('OK')