Dinleme soketini python iş parçacığındaki kapatın

Question

Ağ iletişimi için yuvalar hakkında bilgi edinmek için bir sorunum var. Bağlantıları dinleyen ve istemcileri bağlamaya yönelik süreçler oluşturan basit bir iş parçacığı yaptım, sorunum olsa da, socket.accept() - çağrıyı iptal etmenin bir yolunu bulamadığım için iş parçacığının düzgün bir şekilde katılmasını sağlayamam. programdan çıkmak istediğimde.

Kodum şunun gibi görünüyor;

class ServerThread(threading.Thread): 

    def __init__(self, queue, host, port): 
     threading.Thread.__init__(self) 
     self.queue = queue 
     self.running = True 
     self.hostname = host 
     self.port = port 

    def run(self): 
     self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
     self.socket.bind((self.hostname, self.port)) 
     self.socket.listen(1) 
     while self.running: 
      try: 
       conn, address = self.socket.accept() 
       process = Process(target=server_slave, args=(conn, address, self.queue)) 
       process.daemon = True 
       process.start() 
      except socket.timeout: 
       pass 

    def stop(self): 
     self.running = False 
     self.socket.close() 

Ben self.setDaemon(True) ayarlama ve sadece büyük çöpçüyle şeyi teslim, ana programdan çıkmadan kapatmak için programı almak başarmış - ama bu kötü bir çözüm gibi görünüyor. Ayrıca soket için bir zaman aşımı ayarlamayı denedim, ancak bu, [Errno 35] Resource temporarily unavailable almamın sonucudur (gerçek zaman aşımından bağımsız olarak, yıllara ayarladığım zaman bile ...).

Neyi yanlış yapıyorum? İpliği aptalca tasarlamış mıyım yoksa bağlantıları kabul etmekle ilgili bir şey özledim mi?

Answer 1

İş parçacığının kapanmasını sağlamanın bir yolu sokete bağlantı yapmak gibi görünüyor, böylece iş parçacığı tamamlanmaya devam ediyor.

def stop(self): 
    self.running = False 
    socket.socket(socket.AF_INET, 
        socket.SOCK_STREAM).connect((self.hostname, self.port)) 
    self.socket.close() 

Bu çalışır, ancak en uygun olmayabilir gibi hala hissediyor ...

Answer 2

Çoğu durumda, bir kez bağlantı kabul edilir yeni bir iş parçacığı veya süreci açılacaktır. Bağlantıyı kapatmak için while döngüsünü kırın. Çöp toplama işlemi iş parçacığı veya işlemi kaldıracak, ancak katılım hiçbirinin geride kalmamasını sağlayacaktır.

Kalıcı soketler, kullanıcı kapandığında veya zaman aşımına uğradığında kapanır. Kalıcı olmayan, statik web sayfaları gibi bilgileri gönderdikten sonra kapanır.

Python'da kalıcı bir soket sunucusuna iyi bir örnek. CPU'ya bağlı görevler için çoklu çekirdekler arasında çalışabileceği anlamına gelen çoklu işlemeyi kullanır. Daha yaygın olarak multithreading olarak bilinir.

import socket 
import multiprocessing 

def run(): 
    host = '000.000.000.000' 
    port = 1212 
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
    sock.bind(('', port)) 
    sock.listen(3) 
    while True: 
     p = multiprocessing.Process(target=worker, args=sock.accept()).start() 
def worker(conn, addr): 
    while True: 
     if data == '': 
      #remote connection closed 
      break 
     if len(dataList) > 2: 
      # do stuff 
      print 'This code is untested' 

run() 

Answer 3

çözüm

1. sağ accept