继上述两个答复之后,我意外地将工作推到答案。 感谢你的答复。

如果有人想这样做的话,我把完整的法典放在一边:

import subprocess
from threading import Thread
import time
import sys
import logging
import tempfile
import os

import game_playing_module

class Pusher(Thread):
    def __init__(self, source, dest, proc, name):
        Thread.__init__(self)
        self.source = source
        self.dest = dest
        self.name = name
        self.proc = proc

    def run(self):
        while (self.proc.poll()==None) and
              (not self.source.closed) and (not self.dest.closed):
            line = self.source.readline()
            logging.info( %s: %s  % (self.name, line[:-1]))
            self.dest.write(line)
            self.dest.flush()

def get_reader_writer():
    fd_read, fd_write = os.pipe()
    return os.fdopen(fd_read,  r ), os.fdopen(fd_write,  w )

def connect(exe):
    logging.basicConfig(level=logging.DEBUG,
                        format= %(message)s ,
                        filename=LOG_FILE_NAME,
                        filemode= w )

    program_to_grader_reader, program_to_grader_writer =
                              get_reader_writer()

    grader_to_program_reader, grader_to_program_writer =
                              get_reader_writer()

    p1 = subprocess.Popen(exe, shell=False, stdin=subprocess.PIPE, stdout=subprocess.PIPE)        

    old_stdin = sys.stdin
    old_stdout = sys.stdout

    sys.stdin = program_to_grader_reader
    sys.stdout = grader_to_program_writer

    push1 = Pusher(p1.stdout, program_to_grader_writer, p1,  1 )
    push2 = Pusher(grader_to_program_reader, p1.stdin, p1,  2 )

    push1.start()
    push2.start()

    game_playing_module.play()

    sys.stdin = old_stdin
    sys.stdout = old_stdout

    fil = file(LOG_FILE,  r )
    data = fil.read()
    fil.close()
    return data

if __name__== __main__ :
    if len(sys.argv) != 2:
        print  Usage: connect.py exe 
        print sys.argv
        exit()
    print sys.argv
    print connect(sys.argv[1])

关于Windows,请看(Named或 Anonymous) 管道。

为与Windows的管道合作,可使用。 Windows推广(pywin32),或。 特殊用途模块win32 <>a>,提供双向双向推进器的接口。 其中包括实施<代码>popen[234](的方便功能。

见how-to-use-win32-apis-with-python。 和类似的SO问题(并非专门针对管道,而是指有用的信息)。

关于跨平台解决办法,我建议把类似档案的物体放在当地东道方(127.0.0.1)的备案量之上,即计算IDLE在违约时如何解决与你非常相似的问题。

<代码>管道()将匿名管道或视窗上标明的管道退回,这种管道非常轻重和高效。

TCP sockets(如user1495323所建议的) 重量更重:例如,你可以看到这些港口有净地位,每个港口都需要一个港口号码,现有港口的数量限于每个同龄人64k(例如从当地东道方到当地东道)。

• You can t use select() for nonblocking I/O on Windows, because they re not sockets.
• There s no apparent way to read() with a timeout, and
• Even making them non-blocking is difficult.

可在makefile()>上填入成色的卷宗中填入,从而能够使用to 直接排出或中继器。 因此,在某些使用案件中,例如从一对一对二者发送<代码>stdout,是一种有吸引力的选择。

可按自动签字的港口号码(基于_excellent Zhu socket HOWTO):

with closing(socket.socket(socket.AF_INET, socket.SOCK_STREAM)) as input_socket:
    # Avoid socket exhaustion by setting SO_REUSEADDR <https://stackoverflow.com/a/12362623/648162>:
    input_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

    # localhost doesn t work if the definition is missing from the hosts file,
    # and 127.0.0.1 only works with IPv4 loopback, but socket.gethostname()
    # should always work:
    input_socket.bind((socket.gethostname(), 0))
    random_port_number = input_socket.getsockname()[1]
    input_socket.listen(1)

    # Do something with input_socket, for example pass it to another thread.

    output_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # close() should not strictly be necessary here, but since connect() could fail, it avoids leaking fds
    # in that case. "If a file descriptor is given, it is closed when the returned I/O object is closed".
    with output_socket:
        output_socket.connect((socket.gethostname(), random_port_number))

with input_socket:
    while True:
        readables, _, _ = select.select([input_socket], [], [input_socket], 1.0)

        if len(readables) > 0:
            input_conn, addr = self.input_socket.accept()
            break

    with input_conn:
        while True:
            readables, _, errored = select.select([input_conn], [], [input_conn], 1.0)
            if len(errored) > 0:
                print("connection errored, stopping")
                break

            if len(readables) > 0:
                read_data = input_conn.recv(1024)
                if len(read_data) == 0:
                    print("connection closed, stopping")
                    break
                else:
                    print(f"read data: {read_data!r}")