Python3 主线程新开一条子线程执行while循环造成主线程阻塞

chendaxians

1. import socket  # 导入 socket 模块
   
2. import threading
   
3. 
   
4. from flask import Flask
   
5. from flask import render_template
   
6. from flask import request
   
7. import time
   
8. 
   
9. 
   
10. def send_to_open():
    
11.     global c
    
12. 
    
13.     a1 = "01 0F 00 00 00 04 01 00 3E 96"
    
14.     a2 = "01 05 00 02 FF 00 2D FA"
    
15.     a3 = "01 05 00 03 FF 00 7C 3A"
    
16.     a4 = "01 0F 00 00 00 04 01 00 3E 96"
    
17. 
    
18.     print(bytes.fromhex(a1))
    
19.     c.send(bytes.fromhex(a1))
    
20.     time.sleep(0.5)
    
21. 
    
22.     print(bytes.fromhex(a2))
    
23.     c.send(bytes.fromhex(a2))
    
24.     time.sleep(0.5)
    
25. 
    
26.     print(bytes.fromhex(a3))
    
27.     c.send(bytes.fromhex(a3))
    
28.     time.sleep(3)
    
29. 
    
30.     print(bytes.fromhex(a4))
    
31.     c.send(bytes.fromhex(a4))
    
32. 
    
33. 
    
34. def kill_socket():
    
35.     global c
    
36.     c.close()
    
37. 
    
38. 
    
39. def connect():
    
40.     s = socket.socket()  # 创建 socket 对象
    
41.     host = "0.0.0.0"  # 获取本地主机名
    
42.     port = 6666  # 设置端口
    
43.     s.bind((host, port))  # 绑定端口
    
44.     s.listen(1)  # 等待客户端连接
    
45.     a, addr = s.accept()  # 建立客户端连接
    
46.     return a
    
47. 
    
48. 
    
49. # 按间距中的绿色按钮以运行脚本。
    
50. def open_door_test():
    
51.     # 全局变量
    
52.     # qos：互斥锁
    
53.     # c： socket连接对象
    
54.     global c
    
55.     global qos
    
56.     if qos == 1:
    
57. 
    
58.         qos = 0
    
59.         try:
    
60.             send_to_open()
    
61. 
    
62.         except:
    
63.             print('关闭了正在占线的链接！')
    
64.             kill_socket()
    
65.             print('关闭实例')
    
66. 
    
67.             c = connect()
    
68.             print('新建实例')
    
69. 
    
70.             send_to_open()
    
71.             print('重新开门')
    
72. 
    
73.         qos = 1
    
74. 
    
75. 
    
76. def test_connect():
    
77.     global c
    
78.     global qos
    
79.     a1 = "01 0F 00 00 00 04 01 00 3E 96"
    
80.     while True:
    
81.         if qos == 1:
    
82.             try:
    
83.                 print(bytes.fromhex(a1))
    
84.                 c.send(bytes.fromhex(a1))
    
85.                 time.sleep(0.5)
    
86.                 c.send(bytes.fromhex(a1))
    
87.                 time.sleep(0.5)
    
88.                 c.send(bytes.fromhex(a1))
    
89.                 time.sleep(0.5)
    
90.                 c.send(bytes.fromhex(a1))
    
91.                 time.sleep(0.5)
    
92.                 time.sleep(600)
    
93.             except:
    
94.                 print('关闭了正在占线的链接！')
    
95.                 kill_socket()
    
96.                 print('关闭实例')
    
97. 
    
98.                 c = connect()
    
99.                 print('新建实例')
    
100. 
     
101. 
     
102. app = Flask(__name__)
     
103. c = connect()
     
104. qos = 1
     
105. User_admin = ['qqbot', '1007800006', '2200475850', '1821269010', '1005944615', '1038888008', 'hardware']
     
106. 
     
107. 
     
108. @app.route('/', methods=['GET', 'POST'])
     
109. def index():
     
110.     if request.args.get('user') in User_admin:
     
111.         open_door_test()
     
112.         return render_template('index.html')
     
113.     else:
     
114.         return render_template('bad.html')
     
115. 
     
116. 
     
117.     app.run(port=14725, host='0.0.0.0')
     
118. 
     
119. if __name__ == "__main__":
     
120.     conn = threading.Thread(target=test_connect())
     
121.     conn.start()
     
122.     app.run(port=14725, host='0.0.0.0')
     
123. 
     

复制代码

nahongyan1997

不要用锁就会阻塞住了，每个实例都用不同的变量名或者直接装在列表里就不会用变量名的干涉了。。