Wie man ein hintergrund Verfahren ständig überprüfen, während für die Eingangs - threading?

Da Sie möchten, dass der server-Prozess mit dem client, während in der gleichen Zeit, die input von der server stdin, können Sie nur die gesamte aktuelle server-code in eine Thread, dann wartet input von stdin.

import socket
from time import sleep
import threading

def process():
    sock = socket.socket()
    sock.bind(("127.0.0.1",12346))
    sock.listen(3)
    print "Waiting on connection"
    conn = sock.accept()
    print "Client connected"

    while True:
        m = conn[0].recv(4096)
        conn[0].send(m[::-1])

    sock.shutdown(socket.SHUT_RDWR)
    sock.close()

thread = threading.Thread(target=process)
thread.daemon = True
thread.start()
while True:
    exit_signal = raw_input('Type "exit" anytime to stop server\n')
    if exit_signal == 'exit':
        break

und Sie können entfernen Sie die "exit" - Check-in client.

In diesem code, den der server tut nichts, nachdem der client die Verbindung trennen, obwohl, es wird gerade warten Sie, bis "exit" eingegeben werden die stdin. Möchten Sie vielleicht erweitern Sie den code, um die server in der Lage zu akzeptieren, neue Kunden, da Sie nicht möchten, dass der client die Möglichkeit haben, schließen Sie den server. In diesem Fall können Sie eine weitere while Schleife aus conn = sock.accept() zu sock.close().

Und wie @usmcs vorgeschlagen, wenn Sie nicht haben, andere Befehle werden an den server gesendet, es wird besser sein, wenn Sie mit STRG-C (KeyboardInterrupt) statt, so brauchen Sie nicht den Faden, während es noch Ende der server ordnungsgemäß (d.h. keine Fehler durch die Tastenkombination STRG-C gemeldet) mit diesem code:

import socket
from time import sleep
import threading

sock = socket.socket()
sock.bind(("127.0.0.1",12346))
sock.listen(3)
print "Waiting on connection"
conn = sock.accept()
print "Client connected"

while True:
    try:
        m = conn[0].recv(4096)
        conn[0].send(m[::-1])
    except KeyboardInterrupt:
        break

sock.close()

Nahm ich einen Kern hatte ich bereits veröffentlicht, für den Aufbau einer pre-Gabel-JSON-RPC-Server in Python und verändert den code um dieses problem zu lösen. Kernaussage Hier: https://gist.github.com/matthewstory/4547282

$ python server.py localhost 9999 5
exit
$

Suchen mehr in warum das funktioniert. Die wichtigsten Gabel laicht N viele Gabeln (im Beispiel oben 5), von denen jede geht in einen accept-Schleife:

# simple pre-fork server, fork before accept
for i in range(int(argv[2])):
    # fork our current process
    pid = os.fork()

    # if we are the child fork ...
    if 0 == pid:
        # die without unhandled exception
        for signum in ( signal.SIGINT, signal.SIGTERM, ):
            signal.signal(signum, _gogentle)

        # under the hood, this calls `socket.accept`
        s.serve_forever()
        os._exit(0)

    # if we are the papa fork
    else:
        _PIDS.append(pid)

Diese Kind Gabeln kümmert sich um alle eingehenden Anfragen zu localhost:9999. Die wichtigsten Gabel fällt dann in ein select/waitpid combo-Schleife:

# setup signal relaying for INT and TERM
for signum in ( signal.SIGINT, signal.SIGTERM, ):
    signal.signal(signum, _kronos)

# wait on the kids
while len(_PIDS):
    # 1s timeout here means we're checking for exiting children at most
    # 1x per second, prevents a busy loop
    reads, _, _ = select.select([sys.stdin], [], [], 1)
    if sys.stdin in reads:
        # blocking, read 1 line
        cmd = sys.stdin.readline()
        # kill ourselves ... kronos will propegate
        if cmd.strip() == 'exit':
            os.kill(os.getpid(), signal.SIGTERM)

    # check for exited children, non-blocking
    while True:
        pid, rc = os.waitpid(-1, os.WNOHANG)
        if not pid:
            break
        _PIDS.remove(pid)

Den select wird entweder darauf hindeuten, dass stdin ist bereit zum Lesen, in diesem Fall werden wir Lesen 1 Zeile von stdin, oder es wird timeout nach 1s, in welchem Fall es fallen wird-direkt durch unsere check für alle verlassenen Kinder (mit os.waitpid mit der WNOHANG flag).