python for threading 返回多线程数据实例

#!/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()

猜你喜欢

转载自blog.csdn.net/weixin_41622043/article/details/87874995