#!/usr/bin/env python3
# -*- coding: utf-8 -*-
import threading as td
from queue import Queue
# 执行函数
def job(data,backValue):
for i in range(len(data)):
data[i] = data[i] ** 2
backValue.put(data) # 多线程调用的函数不能用return返回值
# 在多线程函数中定义一个Queue,用来保存返回值,代替return,定义一个多线程列表,初始化一个多维数据列表,用来处理
def multithreading():
# backValue中存放返回值,代替return的返回值
backValue = Queue()
# 线程集合
threads = []
# 数据数组
data = [[1, 2, 3], [3, 4, 5], [4, 4, 4], [5, 5, 5]]
# 在多线程函数中定义四个线程,启动线程,将每个线程添加到多线程的列表中
# 定义四个线程
for i in range(4):
# Thread首字母要大写,被调用的job函数没有括号,只是一个索引,参数在后面
t1 = td.Thread(target=job, args=(data[i], backValue))
t1.start() # 开始线程
threads.append(t1) # 把每个线程append到线程列表中
# 分别join四个线程到主线程
for i in threads:
i.join()
# 定义一个空的列表results,将四个线运行后保存在队列中的结果返回给空列表results
results = []
for _ in range(4):
results.append(backValue.get()) # q.get()按顺序从q中拿出一个值
# 打印返回值
print(results)
if __name__=='__main__':
multithreading()
python for threading 返回多线程数据实例
猜你喜欢
转载自blog.csdn.net/weixin_41622043/article/details/87874995
今日推荐
周排行