Вероятно исправлена проблема с потоками

main
none 8 months ago
parent ed6ecbd282
commit 8b7c0772c1

@ -88,7 +88,7 @@ def server(http_port):
except: except:
print("SERVER FALLED") print("SERVER FALLED")
def recv(q, s): def recv(data):
okay = False okay = False
while not okay: while not okay:
try: try:
@ -96,9 +96,11 @@ def recv(q, s):
okay = True okay = True
except: except:
pass pass
q.put(data) # q.put(data)
import multiprocessing as mp import multiprocessing as mp
from time import time
from threading import Thread
# op = operation # op = operation
def client(port, op = "ping"): def client(port, op = "ping"):
host = 'jetwork.404.mn' host = 'jetwork.404.mn'
@ -116,6 +118,7 @@ def client(port, op = "ping"):
s.send(op.encode()) s.send(op.encode())
'''
# Канал обмена процесс - наша функция # Канал обмена процесс - наша функция
q = mp.Queue() q = mp.Queue()
# Стартуем процесс получения ответа # Стартуем процесс получения ответа
@ -134,6 +137,30 @@ def client(port, op = "ping"):
p.terminate() p.terminate()
s.close() s.close()
'''
data = None
ping = Thread(target = recv, args=(data,))
ping.daemon = True
ping.start()
'''
# Засекаем когда мы начали ждать
start = time()
# Ждём 10 секунд
while time() - start < 3:
pass
#try:
# ping._stop()
#except:
# pass
ping.kill()
'''
ping.join(5)
return data return data
elif op[:4] == "get_": elif op[:4] == "get_":
@ -234,3 +261,6 @@ def port_check(your_port):
ports.append(port) ports.append(port)
return ports return ports
#print(client(44, "ping"))

Loading…
Cancel
Save