1、正常多线程-继承式调用

import threading

thread_max_num = threading.Semaphore(10) # 设置最大线程数为10

class MyThread(threading.Thread):

def __init__(self, param):

threading.Thread.__init__(self)

self.param = param

def run(self):

with thread_max_num: # 设置最大线程数

# 单个请求代码

self.result = fuc(self.param)

def get_result(self):

try:

return self.result

except Exception:

return None

if __name__ == '__main__':

params = []

ths = []

result_list = []

for param in params:

th = MyThread(param)

th.start()

ths.append(th)

for th in ths:

result_list.append(th.get_result())

2、正常多线程-直接调用

import threading

_result = []

ths = [] # 初始化线程list

params = []

def run(param):

global _result

with thread_max_num: # 设置最大线程数

# 单个请求代码

result = None

_result.append(result)

for i in params:

th = threading.Thread(target=run, args=(param, ))

th.start()

ths.append(th)

for th in ths:

th.join()

print(_result)

3、线程池

from multiprocessing import Pool

params = []

def run(param):

pass

pool = Pool(10) # 设置最大线程数为10

ret = pool.map(run, params)

4、协程-gevent

from gevent.pool import Pool

from gevent import monkey;monkey.patch_all()

import gevent

params = []

def run(param):

pass

p = Pool(10)

g_list = []

for param in params:

g = p.spawn(run, param)

g_list.append(g)

gevent.joinall(g_list)

result_list = []

for g in g_list:

result_list.append(g.value)

5、多进程-继承式调用

from multiprocessing import Process

class MyProcess(Process):

def __init__(self):

super().__init__(param)

self.param = param

def run(self):

pass

if __name__ == '__main__':

params = []

for param in params:

pr = MyProcess(param)

pr.start()