Wie tauschen Sie Daten zwischen einem übergeordneten und Gabel-Kind-Prozess in Python?

Ich bin mir ziemlich sicher, würde man dies tun, indem Sie die os.plock(op) - Funktion, aber ich habe keine Ahnung, wie. Auch, wenn es ein besserer Weg gibt, wäre ich dankbar zu erfahren. Code-snippets sind sehr willkommen.

InformationsquelleAutor | 2008-10-20
  1. 14

    Teilprozess ersetzt os.popen, os.system, os.spawn, popen2 und Befehle. Ein einfaches Beispiel für Rohrleitungen wäre:

    p1 = Popen(["dmesg"], stdout=PIPE)
p2 = Popen(["grep", "hda"], stdin=p1.stdout, stdout=PIPE)
output = p2.communicate()[0]

    Können Sie auch ein memory-mapped-Datei mit dem flag=MAP_SHARED für shared memory zwischen Prozessen.

    multiprocessing abstracts sowohl Rohre und shared memory und sorgt für eine höhere level-Schnittstelle. Ergriffen von der Verarbeitung, Dokumentation:

    from multiprocessing import Process, Pipe

def f(conn):
    conn.send([42, None, 'hello'])
    conn.close()

if __name__ == '__main__':
    parent_conn, child_conn = Pipe()
    p = Process(target=f, args=(child_conn,))
    p.start()
    print parent_conn.recv()   # prints "[42, None, 'hello']"
    p.join()
    InformationsquelleAutor Florian Bösch
  2. 8

    Werfen Sie einen Blick auf die multiprocessing Modul neues in python 2.6 (auch verfügbar für frühere Versionen ein pyprocessing

    Hier ist ein Beispiel aus den docs illustrieren die Weitergabe von Informationen über ein Rohr zum Beispiel:

    from multiprocessing import Process, Pipe

def f(conn):
    conn.send([42, None, 'hello'])
    conn.close()

if __name__ == '__main__':
    parent_conn, child_conn = Pipe()
    p = Process(target=f, args=(child_conn,))
    p.start()
    print parent_conn.recv()   # prints "[42, None, 'hello']"
    p.join()
    • Man könnte noch die Wert -, Array-und der Manager-Klassen zur Verfügung gestellt von multiprocessing, die es ermöglichen, Daten gemeinsam nutzen: docs.python.org/library/...
    InformationsquelleAutor Brian
  3. 5

    Dies ist sehr viel, Python-unabhängig! Es ist ein klassisches Beispiel von Unix interprocess communication. Eine gute option ist die Verwendung popen() zum öffnen einer pipe zwischen parent-und child-Prozesse, und die übergabe von Daten/Nachrichten hin und her entlang der Leitung.

    Werfen Sie einen Blick auf die subprocess - Modul, bis die nötigen Leitungen automatisch während der Laichzeit Kind-Prozesse.

    InformationsquelleAutor Dan Lenski
  4. 2

    Haben Sie zwei Möglichkeiten: os.popen* im os Modul, oder verwenden Sie die subprocess Modul den gleichen Effekt. Das Python-Handbuch hat Recht-Dokumentation und Beispiele für popen und Teilprozess.

    InformationsquelleAutor mipadi
  5. 0

    Wenn Sie das tun, low-level-Betriebssystem "forking" und wirklich wollen, um zu vermeiden, mit pipes ist es möglich, shared memory-mapped-Dateien sowie. Dies ist nicht annähernd so schön wie mit subprocess oder popen Rohre, sondern unter anderem auch die Antwort auf Vollständigkeit...

    Gibt es eine vollständiges Beispiel hier, aber im Grunde können Sie kombinieren die os Datei-handling und mmap Module:

    import mmap, os, tempfile
fd, tmpfile = tempfile.mkstemp()
os.write(fd, '\x00' * mmap.PAGESIZE)
os.lseek(fd, 0, os.SEEK_SET)
child_pid = os.fork()
if child_pid:
    buf = mmap.mmap(fd, mmap.PAGESIZE, mmap.MAP_SHARED, mmap.PROT_READ)
    os.waitpid(child_pid, 0)
    child_message = buf.readline()
    print(child_message)
    os.close(fd)
else:
    buf = mmap.mmap(fd, mmap.PAGESIZE, mmap.MAP_SHARED, mmap.PROT_WRITE)
    buf.write('testing\n')
    os.close(fd)
    InformationsquelleAutor David Fraser
Schreibe einen Kommentar