[已解决]Thread 线程锁后，返回值问题？

abababab

1. from threading import Thread
   
2. from threading import Lock
   
3. import time
   
4. 
   
5. n = 100                             #共100张票
   
6. def task():
   
7.     global n                       
   
8.     mutex.acquire()                 #上锁
   
9.     # temp = n                        #赋值给临时变量
   
10.     # time.sleep(0.1)                 #休眠0.1秒
    
11.     # n = temp - 1                    #数量减1
    
12.     time.sleep(0.1)                 #休眠0.1秒
    
13.     n = n-1
    
14.     print("购买成功,剩余%d张电影票"%n)
    
15.     mutex.release()                 #释放锁
    
16.     return ("购买成功,剩余%d张电影票"%n)
    
17. 
    
18. if __name__ == "__main__":
    
19.     mutex = Lock()                  #实例化LOCK类
    
20.     t_list = []                     #初始化一个列表
    
21.     for i in range(10):
    
22.         t = Thread(target=task)     #实例化线程类
    
23.         t_list.append(t)            #将线程实例存入列表中
    
24.         t.start()                   #创建线程
    
25.    
    
26.     for t in t_list:
    
27.         t.join()                    #等待子线程结束
    
28.     data = t.join()
    
29.     print("data ",data )

复制代码

怎么在主函数取回task的返回值？  data  取回 none

最佳答案

月排行榜 / 总排行榜

isdkz

2023-5-4 14:50:40

abababab 发表于 2023-5-4 14:47
TypeError: task() takes 0 positional arguments but 1 was given  

[None] * 10 是啥意思？

这里的  [None] * 10  是创建一个包含 10 个  None  元素的列表。当我们使用  executor.map()  函数时，它需要将传递给  task()  函数的参数作为第二个参数。由于我们的  task()  函数没有接收任何参数，所以这里产生了错误。

为了修复这个问题，您可以将  task()  函数修改为接受一个参数（即使我们实际上不使用它）。下面是修改后的代码：

1. from concurrent.futures import ThreadPoolExecutor
   
2. import time
   
3. from threading import Lock
   
4. 
   
5. n = 100                             # 共100张票
   
6. mutex = Lock()                      # 实例化LOCK类
   
7. 
   
8. 
   
9. def task(dummy):                    # 修改这里，添加一个参数
   
10.     global n
    
11.     global mutex
    
12.     with mutex:                     # 上锁
    
13.         time.sleep(0.1)             # 休眠0.1秒
    
14.         n = n - 1                   # 数量减1
    
15.         result = "购买成功,剩余%d张电影票" % n
    
16.     return result                   # 释放锁
    
17. 
    
18. 
    
19. if __name__ == "__main__":
    
20.     with ThreadPoolExecutor(max_workers=10) as executor:
    
21.         # 提交任务并获取返回值
    
22.         results = list(executor.map(task, [None] * 10))
    
23. 
    
24.     for result in results:
    
25.         print(result)
    
26. 
    
27.     print("data ", results[-1])
    

复制代码

现在， task()  函数接受一个名为  dummy  的参数，但我们在函数内部并未使用它。这样， executor.map()  可以正常工作，因为它会将列表  [None] * 10  中的每个  None  元素作为参数传递给  task()  函数。

跳转到最佳答案楼层

isdkz

在您的代码中，您尝试通过调用 t.join() 来获取 task() 函数的返回值。然而， Thread 对象的 join() 方法并不返回调用线程的返回值。为了解决这个问题，您可以使用 concurrent.futures 库中的 ThreadPoolExecutor ，它允许您轻松地获取线程返回值。请看下面的示例：

1. from concurrent.futures import ThreadPoolExecutor
   
2. import time
   
3. from threading import Lock
   
4. 
   
5. n = 100                             # 共100张票
   
6. mutex = Lock()                      # 实例化LOCK类
   
7. 
   
8. 
   
9. def task():
   
10.     global n
    
11.     global mutex
    
12.     with mutex:                     # 上锁
    
13.         time.sleep(0.1)             # 休眠0.1秒
    
14.         n = n - 1                   # 数量减1
    
15.         result = "购买成功,剩余%d张电影票" % n
    
16.     return result                   # 释放锁
    
17. 
    
18. 
    
19. if __name__ == "__main__":
    
20.     with ThreadPoolExecutor(max_workers=10) as executor:
    
21.         # 提交任务并获取返回值
    
22.         results = list(executor.map(task, [None] * 10))
    
23. 
    
24.     for result in results:
    
25.         print(result)
    
26. 
    
27.     print("data ", results[-1])
    

复制代码

在这个示例中，我们使用了 ThreadPoolExecutor 来创建和执行线程。通过将 task 函数映射到 [None] * 10 列表，我们创建了10个线程，每个线程都执行一次 task 函数。 executor.map() 方法会返回一个结果列表，其中包含 task 函数的返回值。最后，我们可以从结果列表中获取我们需要的返回值。

abababab

isdkz 发表于 2023-5-4 14:22
在您的代码中，您尝试通过调用 t.join() 来获取 task() 函数的返回值。然而， Thread 对象的 join() 方法并 ...

TypeError: task() takes 0 positional arguments but 1 was given  

[None] * 10 是啥意思？

isdkz

abababab 发表于 2023-5-4 14:47
TypeError: task() takes 0 positional arguments but 1 was given  

[None] * 10 是啥意思？

这里的  [None] * 10  是创建一个包含 10 个  None  元素的列表。当我们使用  executor.map()  函数时，它需要将传递给  task()  函数的参数作为第二个参数。由于我们的  task()  函数没有接收任何参数，所以这里产生了错误。

为了修复这个问题，您可以将  task()  函数修改为接受一个参数（即使我们实际上不使用它）。下面是修改后的代码：

1. from concurrent.futures import ThreadPoolExecutor
   
2. import time
   
3. from threading import Lock
   
4. 
   
5. n = 100                             # 共100张票
   
6. mutex = Lock()                      # 实例化LOCK类
   
7. 
   
8. 
   
9. def task(dummy):                    # 修改这里，添加一个参数
   
10.     global n
    
11.     global mutex
    
12.     with mutex:                     # 上锁
    
13.         time.sleep(0.1)             # 休眠0.1秒
    
14.         n = n - 1                   # 数量减1
    
15.         result = "购买成功,剩余%d张电影票" % n
    
16.     return result                   # 释放锁
    
17. 
    
18. 
    
19. if __name__ == "__main__":
    
20.     with ThreadPoolExecutor(max_workers=10) as executor:
    
21.         # 提交任务并获取返回值
    
22.         results = list(executor.map(task, [None] * 10))
    
23. 
    
24.     for result in results:
    
25.         print(result)
    
26. 
    
27.     print("data ", results[-1])
    

复制代码

现在， task()  函数接受一个名为  dummy  的参数，但我们在函数内部并未使用它。这样， executor.map()  可以正常工作，因为它会将列表  [None] * 10  中的每个  None  元素作为参数传递给  task()  函数。