網站首頁 編程語言 正文
Python獲取多線程返回結果
在 Python 的多線程中,有時候我們會需要每一個線程中返回的結果。
然而,在經過我的多番嘗試、以及網上各種博客顯示,在 Python3 中是無法獲得單個線程中返回的結果的,因此我們需要定義一個類來實現這個過程
這個類的定義如下:
class MyThread(threading.Thread):
? ? def __init__(self, func, args = ()):
? ? ? ? super(MyThread, self).__init__()
? ? ? ? self.func = func
? ? ? ? self.args = args
? ??
? ? def run(self):
? ? ? ? self.result = self.func(*self.args)
? ? def get_result(self):
? ? ? ? try:
? ? ? ? ? ? return self.result
? ? ? ? except Exception:
? ? ? ? ? ? return None
然后我們就可以通過調用這個類里的函數,get_result() 來獲取每個線程中返回的結果了,以下是一個測試的實例,多線程調用一個相加的函數,經過實驗,是能夠獲取到所有線程返回的結果的。
import threading
class MyThread(threading.Thread):
? ? def __init__(self, func, args = ()):
? ? ? ? super(MyThread, self).__init__()
? ? ? ? self.func = func
? ? ? ? self.args = args
? ??
? ? def run(self):
? ? ? ? self.result = self.func(*self.args)
? ? def get_result(self):
? ? ? ? try:
? ? ? ? ? ? return self.result
? ? ? ? except Exception:
? ? ? ? ? ? return None
def add(num):
? ? result = num + 5
? ? return result
if __name__ == '__main__':
? ? data = []
? ? threads = []
? ? nums = [1, 2, 3]
? ? for num in nums:
? ? ? ? t = MyThread(add, args = (num, ))
? ? ? ? threads.append(t)
? ? ? ? t.start()
? ? for t in threads:
? ? ? ? t.join()
? ? ? ? data.append(t.get_result())
? ? print(data)
Python多線程實現
from threading import Thread
def func():
for i in range(100):
print('func',i)
if __name__ == '__main__':
t=Thread(target=func)
t.start()
for i in range(100):
print('main',i)
線程池:
- 一次性開辟一些線程,我們用戶直接給線程池子提交任務,線程任務的調度交給線程池。
from concurrent.futures import ThreadPoolExecutor
def func(name):
for i in range(20):
print(name,i)
if __name__ == '__main__':
#創建線程池
with ThreadPoolExecutor(10) as t:
for i in range(10):
t.submit(func,name=f'線程{i}')
print('over')#等待線程全部執行完畢,才會執行該行代碼
原文鏈接:https://blog.csdn.net/weixin_43354181/article/details/85933378
相關推薦
- 2024-03-09 【Redis】什么是緩存雪崩,如何預防緩存雪崩?
- 2022-05-25 Docker?compose配置文件寫法及命令使用示例_docker
- 2022-06-29 Python解決非線性規劃中經濟調度問題_python
- 2022-12-27 Docker使用Calico網絡模式配置及問題處理方法_docker
- 2022-04-17 Jquery cxSelect多級聯動下拉組件的使用
- 2022-10-25 在IIS上部署Go?API項目_win服務器
- 2023-05-14 python隨機獲取列表中某一元素的方法_python
- 2023-03-03 PostgreSQL死鎖了怎么辦及處理方法_PostgreSQL
- 最近更新
-
- window11 系統安裝 yarn
- 超詳細win安裝深度學習環境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤:Artif
- restTemplate使用總結
- Spring Security之安全異常處理
- MybatisPlus優雅實現加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發現-Nac
- Spring Security之基于HttpR
- Redis 底層數據結構-簡單動態字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列,發送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支