Python线程沲

1
2

    future = self.executor.submit(self.task_work, "single task")
    print(future.result())

1
2
3
4
5

    futures = [self.executor.submit(self.task_work, "mutitask-" + str(i)) for i in range(10)]
    results = [future.result() for future in concurrent.futures.as_completed(futures)]

    res = '\n'.join(str(x) for x in results)
    print(f"{res}")

1
2
3
4
5

    tasks = [str(i) for i in range(5)]
    results = self.executor.map(self.task_work, tasks)

    res = '\n'.join(str(x) for x in results)
    print(f"{res}")

1

    self.executor.shutdown()

1
2
3
4

    # 创建一个线程池，大小默认
    with ThreadPoolExecutor() as executor:
        # 在 with 语句块中使用线程池
        pass

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

import threading
import time
import concurrent.futures
from  concurrent.futures import ThreadPoolExecutor


class ThreadPoolTest(object):
    def __init__(self):
        self.executor = ThreadPoolExecutor()
        pass

    def __del__(self):
        self.executor.shutdown()
        print(f"executor.shutdown {threading.get_ident()}")

    def task_work(self, task_name):
        time.sleep(2)
        print(f"thread id = {threading.get_ident()}, task_name:{task_name}")

        return task_name

    def start(self):
        # 提交单个任务到线程沲
        print(f"---提交单个任务---")
        future = self.executor.submit(self.task_work, "single task")
        print(future.result())

        # 批量提交多个任务到线程池
        print(f"---提交多个个任务---")
        futures = [self.executor.submit(self.task_work, "mutitask-" + str(i)) for i in range(10)]
        results = [future.result() for future in concurrent.futures.as_completed(futures)]

        res = '\n'.join(str(x) for x in results)
        print(f"{res}")

        # 使用 map 方法可以同时提交多个任务，其中 function 是需要执行的任务函数，iterable 是任务的参数迭代器。
        # map 方法会顺序地将参数迭代器中的每个元素传递给任务函数，并返回结果的生成器。
        print(f"---map方法提交多个任务---")

        tasks = [str(i) for i in range(5)]
        results = self.executor.map(self.task_work, tasks)

        res = '\n'.join(str(x) for x in results)
        print(f"{res}")

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

---提交单个任务---
thread id = 13006442496, task_name:single task
single task
---提交多个个任务---
thread id = 13023232000, task_name:mutitask-1
thread id = 13157548032, task_name:mutitask-9
thread id = 13073600512, task_name:mutitask-4
thread id = 13107179520, task_name:mutitask-6
thread id = 13006442496, task_name:mutitask-0
thread id = 13140758528, task_name:mutitask-8
thread id = 13056811008, task_name:mutitask-3
thread id = 13040021504, task_name:mutitask-2
thread id = 13123969024, task_name:mutitask-7
thread id = 13090390016, task_name:mutitask-5
mutitask-1
mutitask-9
mutitask-4
mutitask-6
mutitask-0
mutitask-8
mutitask-3
mutitask-2
mutitask-7
mutitask-5
---map方法提交多个任务---
thread id = 13073600512, task_name:2
thread id = 13006442496, task_name:4
thread id = 13157548032, task_name:1
thread id = 13107179520, task_name:3
thread id = 13023232000, task_name:0
0
1
2
3
4
executor.shutdown 8635171456

Process finished with exit code 0