专栏首页程序员同行者python多线程获取子线程任务返回值

python多线程获取子线程任务返回值

今天想实现多线程更新资产信息,所以使用到了threading,但是我需要每个线程的返回值,这就需要我在threading.Thread的基础上进行封装

def auto_asset(node):
    ret = salt.remote_grains_execution_sigle(node)
    asset_info={}
    asset_info['os']= ret[node]['oscodename']
    asset_info['kernelrelease']= ret[node]['kernelrelease']
    asset_info['cpu_model']= ret[node]['cpu_model']
    asset_info['dns']= ','.join(ret[node]['dns']['ip4_nameservers'])
    asset_info['serialnumber'] =  ret[node]['serialnumber']
    asset_info['virtual'] =  ret[node]['virtual']
    asset_info['localhost'] = ret[node]['localhost']
    asset_info['mem_total'] =  ret[node]['mem_total']
    asset_info['num_cpus'] =  ret[node]['num_cpus']
    asset_info['ip4_interfaces'] = " ".join(ret[node]['ip4_interfaces']['eth0'])
    asset_info['hwaddr_interfaces'] = ret[node]['hwaddr_interfaces']['eth0']
    return asset_info

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  # 如果子线程不使用join方法,此处可能会报没有self.result的错误
        except Exception:
            return None

ass =Asset.objects.all()
ids_list =[ i.inner_ip for i in ass]
files = range(len(ids_list))
t_list = []
t_data = []
for i in files:
    t = MyThread(auto_asset, (ids_list[i],))
    t_list.append(t)
    t.start()
for t in t_list:
    t.join()  # 一定要join,不然主线程比子线程跑的快,会拿不到结果
    t_data.append(t.get_result())
    print(t.get_result())

执行结果

{'localhost': 'VM_75_82_centos', 'hwaddr_interfaces': '52:54:00:95:fe:c8', 'disks': {'/dev/vda1': {'total': '49.09G', 'capacity': '17%', 'avail': '38.96', 'used': '7.63'}}, 'dns': '10.236.158.106,10.236.158.114', 'ip4_interfaces': '10.105.75.82', 'num_cpus': 1, 'serialnumber': 'a1dad25c-8e69-4838-a489-0fe1958e76df', 'os': 'CentOS Linux 7 (Core)', 'mem_total': 1839, 'cpu_model': 'Intel(R) Xeon(R) CPU E5-26xx v4', 'kernelrelease': '3.10.0-514.26.2.el7.x86_64', 'virtual': 'kvm'}
{'localhost': 'wordpress', 'hwaddr_interfaces': 'fa:16:3e:1a:49:72', 'disks': {'/dev/vda1': {'total': '29.99G', 'capacity': '12%', 'avail': '26.54', 'used': '3.45'}}, 'dns': '103.224.222.222,103.224.222.223,8.8.8.8', 'ip4_interfaces': '192.168.0.3', 'num_cpus': 1, 'serialnumber': 'c6bce500-113d-11e7-a010-0425c53afb57', 'os': 'CentOS Linux 7 (Core)', 'mem_total': 1839, 'cpu_model': 'Intel Core Processor (Broadwell, IBRS)', 'kernelrelease': '3.10.0-514.el7.x86_64', 'virtual': 'kvm'}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • python3模块: uuid

    程序员同行者
  • Go使用Makefile构建

    Makefile 是和 make 命令一起配合使用的。它是开源的构建工具,很多大型项目的编译都是通过 Makefile 来组织的。

    程序员同行者
  • golang基础之第一个go程序

    在Go语言中,所有文件必须隶属于某一个包。当前,只需要理解在文件的头部声明一个package name就可以了,其中package为关键字,name为你自己起的...

    程序员同行者
  • 保护连接字符串

    保护连接字符串 摘自MSDN 保护对数据源的访问是安全应用程序最重要的目标之一。为了帮助限制对数据源的访问,必须保护连接信息(例如用户标识、密码和数据源名称)的...

    脑洞的蜂蜜
  • 李嘉诚和邓小平最爱讲的十个故事

    1、获得胜利的方法故事:有人用玻璃把一条蛇和一只青蛙在水池里隔开。开始时,蛇要吃青蛙,它一次次冲向青蛙,却一次次撞到了玻璃隔板上,它吃不着。过了一会,蛇放弃了努...

    小小科
  • Python3中concurrent.futures模块介绍

    第一次接触futures模块是在tornado中,tornado4.0版本使用futures频率很高,因为tornado本身的corouting的异步功能,是需...

    编程思录
  • 【NLP-ChatBot】能闲聊的端到端生成型聊天机器人背后都有哪些技术?

    我们之前介绍过,按照应用场景的不同,聊天机器人可以分为问答系统,对话系统以及闲聊机器人三类。今天我们就来详细讲一讲其中的生成型闲聊机器人。

    用户1508658
  • Golang包——sync

    1.它允许任意读操作同时进行 2.同一时刻,只允许有一个写操作进行 3.并且一个写操作被进行过程中,读操作的进行也是不被允许的 4.读写锁控制下的多个写操...

    羊羽shine
  • Redis系列:项目中哪些常用的命令

    启动和关闭无疑是开启Redis的首要命令,连服务器都不知道启动和关闭何谈使用呢?

    java乐园
  • 【Python入门】Python字符串的45个方法详解

    Python中字符串对象提供了很多方法来操作字符串,功能相当丰富。必须进行全面的了解与学习,后面的代码处理才能更得心应手,编程水平走向新台阶的坚实基础。目前一共...

    黄博的机器学习圈子

扫码关注云+社区

领取腾讯云代金券