Python控制执行线程数

发表于 更新于
本文字数： 607 阅读时长 ≈ 1 分钟

信号量

1
2
3
4
5
6
7
8
9
10
11
12
13
import threading
import time
  
sem=threading.Semaphore(4)
  
def gothread():
  with sem:
    for i in range(8):
      print(threading.current_thread().name,i)
      time.sleep(1)
  
for i in range(15):
  threading.Thread(target=gothread).start()

使用 with 语句会在它包围的代码块内获取关联的锁。 acquire() 和 release() 方法也能调用关联锁的相关方法。

https://docs.python.org/zh-cn/3.6/library/threading.html
https://docs.python.org/zh-cn/3.6/library/concurrency.html

ThreadPoolExecutor

1
2
3
4
5
6
7
8
9
10
sem=threading.Semaphore(4)
  
def gothread(s):
	time.sleep(s)
  
pool = ThreadPoolExecutor(max_workers=10)
for i in range(15):
	pool.submit(gothread, s)

pool.shutdown(wait=True)