python中的线程threading.Thread()

Python中的`threading.Thread()`是一个线程类，用于创建线程的实例。该类接受一个可调用对象作为参数，该可调用对象将在新线程中运行。下面是一个简单的例子：

import threading

def print_numbers():
    for i in range(1, 11):
        print(i)

# 创建线程实例
t = threading.Thread(target=print_numbers)

# 启动线程
t.start()

# 等待线程结束
t.join()

# 主线程结束
print("Done")

在上面的例子中，我们首先定义了一个函数`print_numbers()`，该函数在新线程中运行。然后我们创建了一个线程实例`t`，指定可调用对象为`print_numbers()`。接着我们启动线程`t`，并等待线程结束，最后输出一条消息表示主线程结束。

需要注意的是，Python中的线程是不可预测的，因此无法保证线程执行的顺序和时间。如果需要多个线程之间的同步，需要使用锁、条件变量等同步机制。

相关问题

python threading.thread

Python的threading.Thread类表示在单独的控制线程中运行的活动。有两种方法可以指定这种活动：第一种方法是通过给构造函数传递回调对象来指定活动，例如：
mthread=threading.Thread(target=xxxx,args=(xxxx))
mthread.start()
第二种方法是在子类中重写run()方法，例如：
import threading, time
class MyThread(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)
def run(self):
global n, lock
time.sleep(1)
if lock.acquire():
print n , self.name
n = 1
lock.release()
if "__main__" == __name__:
n = 1
ThreadList = []
lock = threading.Lock()
for i in range(1, 200):
t = MyThread()
ThreadList.append(t)
for t in ThreadList:
t.start()
for t in ThreadList:
t.join()
所以，Python的threading.Thread类可以通过传递回调对象或在子类中重写run()方法来指定活动。<span class="em">1</span><span class="em">2</span><span class="em">3</span>

python终止 threading.Thread运行

可以使用`threading.Thread`类提供的`_stop()`方法来终止线程的运行。该方法会引发`SystemExit`异常，因此需要在线程的`run()`方法中进行异常处理。以下是一个例子：

import threading
import time

class MyThread(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)
        self._running = True

    def run(self):
        global n, lock
        time.sleep(1)
        while self._running:
            if lock.acquire():
                print(n, self.name)
                n += 1
                lock.release()
            time.sleep(1)

    def stop(self):
        self._running = False

if __name__ == "__main__":
    n = 1
    ThreadList = []
    lock = threading.Lock()
    for i in range(1, 5):
        t = MyThread()
        ThreadList.append(t)
    for t in ThreadList:
        t.start()
    time.sleep(5)
    for t in ThreadList:
        t.stop()
    for t in ThreadList:
        t.join()

在上面的例子中，我们创建了一个`MyThread`类，该类继承自`threading.Thread`类，并添加了一个`stop()`方法，该方法将`self._running`设置为`False`，以停止线程的运行。在`run()`方法中，我们使用一个`while`循环来不断地执行线程的任务，同时检查`self._running`的值，以决定是否继续执行任务。在主程序中，我们创建了4个`MyThread`对象，并启动它们的运行。然后，我们等待5秒钟，然后调用每个线程的`stop()`方法，以停止它们的运行。最后，我们等待每个线程完成，然后退出程序。