python threading多线程的一个小问题。

在使用threading 多线程的时候遇到个小问题,正常情况的执行,函数返回结果可以赋值给变量,然后用另一个函数来引用这个变量。但多线程时,赋值给变量的变成这个线程本身,并非函数运行的结果。 有什么办法在使用多线程,又可以正常让函数运算结果赋予给变量。谢谢

import time,threading

def xxx(a,b):
  x = a+b
  print(x)
  return x

def xxx2(c,d):
  x2 = c-d
  print(x2)

# 正常需要实现功能
test1 = xxx(100,200)
test2 = xxx(100,100)
xxx2(test1,test2)

# 通过多线程来实现:
test1 = threading.Thread(target=xxx,args=(100,200))
test2 = threading.Thread(target=xxx,args=(100,100))

test1.start()
test2.start()
test1.join()
test2.join()

#此处类型报错,线程本身不支持xx2函数内的减法
xxx2(test1,test2) 

你的xxx2(test1,test2)给xxx2输入的两个形参是两个线程(test1,test2)。自然不是你想要的结果。

改成:
import time,threading

l1=[]
l2=[]

def xxx(a,b,l):
x = a+b
print(x)
l.append(x)

def xxx2(c,d):
x2 = c-d
print(x2)
return x2

test1 = threading.Thread(target=xxx,args=(100,200,l1))
test2 = threading.Thread(target=xxx,args=(100,100,l2))

test1.start()
test2.start()
test1.join()
test2.join()

xxx2(l1[0],l2[0])

通过两个list来传递线程的执行结果,这样就能把线程的返回值传递出来。

最好通过线程通讯来处理,或者可以借助全局变量

线程池
executor = ThreadPoolExecutor(max_workers=2)
task1 = executor.submit(xxx, 1,2)
task2 = executor.submit(xxx, 2,3)
xxx2(task1.result(),task2.result())