Мой код принимает данные GPS из нескольких источников, агрегирует их и отправляет обратно нескольким клиентам, подключенным к однополосному однократному розетку. Я получил его работу, но выходные потоки, кажется, работают с ресурсами процессора.class ThreadedServerRequestHandler(SocketServer.StreamRequestHandler):
def handle(self):
global SendData
global SendNow
while True:
SendNow
for line in SendData:
self.request.sendall(line)
SendData = []
SendNow = False
return
class ServerThread(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
daemon_threads = True
allow_reuse_address = True
if __name__ == '__main__':
import socket
import threading
address = TxServer
server = ServerThread(address, ThreadedServerRequestHandler)
t = threading.Thread(target=server.serve_forever)
t.setDaemon(True) # don't hang on exit
t.start()
< /code>
Если я изменяю его на остановки ЦП ниже, но он выводит данные только в том случае, если я отправляю клавиш. < /p>
class ThreadedServerRequestHandler(SocketServer.StreamRequestHandler):
def handle(self):
global SendData
global SendNow
while True:
self.data = self.request.recv(1024).strip()
if self.data == '':
print 'closing thread'
break
while SendNow == True:
for line in SendData:
self.request.sendall(line)
SendData = []
SendNow = False
return
< /code>
Есть ли способ приостановить поток до отправки данных? Или я могу моделировать полученное сообщение, чтобы запустить взрыв данных из основной программы?
Подробнее здесь: https://stackoverflow.com/questions/161 ... u-use-high
Python SocketServer Отправить данные в процессор нескольких клиентов. ⇐ Python
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение