Python标准库中from concurrent.futures下的ThreadPoolExecutor。
#!/usr/bin/env python
# -*- coding:utf-8 -*-
# 首先导包
from threading import Thread
# 创建一个线程
t = Thread(target=function_name,args=(function_params1,function_paramsn))
t.start()
# 2. 使用继承的方法创建进程
from threading import Thread
# 创建一个class，必须继承Thread
class MyThread(Thread):
# 继承Thread的类，必须实现run方法，线程就是从这里开始执行的
def run(self):
function_name(self,params1)
def __init__(self,params1):
# 需要执行父类的城市化方法
Thread.__init__(self)
self.params1 = params1
t = MyThread(params1)
s.start()
# 线程等待，使用join方法使子线程执行完毕后，主线程再关闭
from threading import Thread
class MyThread(Thread):
def run(self):
function_name(self,params1)
def __init__(self,params1):
Thread.__init__(self)
self.params1 = params1
t = MyThread(params1)
t.start()
# 只需要加上一句
t.join()
# 如果有多个线程，可以将每个线程放在一个数组中
thread_list= []
for i in range(1,11)
t = MyThread(params1)
thread_list.append(t)
t.start()
# 在这里统一执行线程等待方法
for t in thread_list:
t.join()
