Exemplo 1 Threads
This commit is contained in:
parent
bcd4801dfc
commit
40e9d97a8a
|
|
@ -0,0 +1,23 @@
|
||||||
|
import socket
|
||||||
|
import threading
|
||||||
|
|
||||||
|
servidor = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||||
|
servidor.bind(("0.0.0.0", 5000))
|
||||||
|
servidor.listen()
|
||||||
|
print("Servidor inicializado!!!")
|
||||||
|
|
||||||
|
clientes = []
|
||||||
|
|
||||||
|
def ouvir_cliente(cliente):
|
||||||
|
while True:
|
||||||
|
mensagem = cliente.recv(1024).decode()
|
||||||
|
for socket_cliente in clientes:
|
||||||
|
if socket_cliente != cliente:
|
||||||
|
socket_cliente.send(mensagem)
|
||||||
|
|
||||||
|
while True:
|
||||||
|
cliente, endereco_cliente = servidor.accept()
|
||||||
|
thread = threading.Thread(target=ouvir_cliente, args=[cliente,])
|
||||||
|
thread.start()
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -0,0 +1,19 @@
|
||||||
|
import threading
|
||||||
|
import time
|
||||||
|
|
||||||
|
#Função que será executada pela thread
|
||||||
|
def executar (nome_thread, n_iteracoes):
|
||||||
|
for i in range(n_iteracoes):
|
||||||
|
print (f"Nome da thread: {nome_thread}")
|
||||||
|
time.sleep(2) #Parar por 2s
|
||||||
|
|
||||||
|
t1 = threading.Thread(target=executar,args=["Thread1",15])
|
||||||
|
t2 = threading.Thread(target=executar,args=["Thread2",10])
|
||||||
|
|
||||||
|
t1.start()
|
||||||
|
t2.start()
|
||||||
|
|
||||||
|
t1.join()
|
||||||
|
t2.join()
|
||||||
|
|
||||||
|
print("Final da thread principal!")
|
||||||
Loading…
Reference in New Issue