[已解决]多线程问题

我不是第一个

多线程同时运行时，在遇到特定函数时，怎么只执行一次。
比如遇到验证码时。

最佳答案

月排行榜 / 总排行榜

Mike_python小

2023-9-12 20:53:27

如果在一段时间后又遇到验证码，可以将上述的全局变量 `function_executed` 重新设置为 `False`，以便下次特定函数执行时可以再次执行。

1. import threading
   
2. import time
   
3. 
   
4. # 全局变量，用于标记特定函数是否已经执行
   
5. function_executed = False
   
6. 
   
7. # 特定函数
   
8. def special_function():
   
9.     global function_executed
   
10.     if not function_executed:
    
11.         # 执行特定操作，例如验证码的处理
    
12.         print("执行特定函数")
    
13.         function_executed = True
    
14. 
    
15. # 多线程任务
    
16. def worker():
    
17.     # 其他任务...
    
18. 
    
19.     # 在遇到特定函数时，只执行一次
    
20.     special_function()
    
21. 
    
22.     # 其他任务...
    
23. 
    
24. # 定时重置全局变量
    
25. def reset_variable():
    
26.     global function_executed
    
27.     while True:
    
28.         time.sleep(10 * 60)  # 每隔10分钟重置一次
    
29.         function_executed = False
    
30. 
    
31. # 创建并启动多个线程
    
32. threads = []
    
33. for _ in range(10):
    
34.     t = threading.Thread(target=worker)
    
35.     threads.append(t)
    
36.     t.start()
    
37. 
    
38. # 创建并启动重置全局变量的线程
    
39. reset_thread = threading.Thread(target=reset_variable)
    
40. reset_thread.start()
    
41. 
    
42. # 等待所有线程结束
    
43. for t in threads:
    
44.     t.join()
    
45. 
    
46. # 等待重置线程结束
    
47. reset_thread.join()
    

复制代码

在上述示例中，新增了一个名为 `reset_variable` 的函数，该函数会周期性地重置全局变量 `function_executed`，这里使用了一个循环和 `time.sleep` 来实现定时重置。可以根据实际需求调整重置的时间间隔。

这样，在每次重置后，特定函数又可以被执行一次，以处理后续遇到的验证码或其他需要执行一次的操作。

请注意，对全局变量的访问和修改要进行线程同步，以避免多个线程同时修改导致的竞争条件。可以使用锁或其他同步机制来确保线程安全。

跳转到最佳答案楼层

我不是第一个

Mike_python小 发表于 2023-9-10 08:22
在多线程同时运行时，要想在遇到特定函数时只执行一次，可以使用同步机制来实现。以下是一种可能的解决方案 ...

还有一个问题，如果下次又遇到验证码呢？比如10分钟左右又遇到了验证码。

我不是第一个

1.         global function_executed
   
2.         i = request.i
   
3.         if i >= 5:
   
4.             if not self.function_executed:
   
5.                 self.function_executed = True
   
6.                 time.sleep(30)
   
7.                 print(f'{i}这个是测试用的')
   
8.                 self.function_executed = False
   
9. 
   
10.             print(f'{i}这就很六了')
    
11.         else:
    
12.             print(f'{i}小于五了')

复制代码

我是这样设置的，if not self.function_executed 后面的代码过于复杂，会导致其他线程也进来，所有就立马设置了self.function_executed = True， 等运行完后再设置self.function_executed = False，验证后效果没毛病，不知道有隐患没有。

我不是第一个

Mike_python小 发表于 2023-9-12 20:53
如果在一段时间后又遇到验证码，可以将上述的全局变量 `function_executed` 重新设置为 `False`，以便下次 ...

好像搞错了
第一个线程进去reset_variable执行后，其他线程不执行reset_variable，但同时必须要处于等待状态，因为要过验证码，其他线程必须获取reset_variable的结果才能继续执行。