-1

在 Echo 协议中的 lineReceived 方法中，我想在每次写入 child 时生成一个延迟对象。它将等待结果，然后在子进程处理完数据后打印结果。我需要找到一种方法来做到这一点。现在，MyPP 的函数 outReceived 从子进程中获取结果。

谢谢你

from sys import executable
from os import environ
import os
from twisted.internet import reactor, defer
from twisted.internet.protocol import Protocol
from twisted.internet.protocol import Factory
from twisted.internet import protocol
from twisted.protocols.basic import LineReceiver
import sys
import time
import math

implementation = """
from filter import censor
censor()
"""                         

class Echo(LineReceiver): 

    def lineReceived(self, data): 
        if self.factory.pp == None:
            pp = MyPP()
            self.factory.pp = reactor.spawnProcess(pp, executable, [executable, "-c", implementation], 
                                                                   env=environ, childFDs = {0:"w", 1:"r", 2:"r"})   
        self.factory.pp.writeToChild(0, data+'\r\n')




class EchoFactory(Factory): 

    protocol = Echo 
    pp = None


class MyPP(protocol.ProcessProtocol): 

    def connectionMade(self):  
        print "connectionMade!" 

    def outReceived(self, data): 
        pass




reactor.listenTCP(11111, EchoFactory()) 
print 'in parent', os.getpid() 
reactor.run()
4

1 回答 1

1

您需要childDataReceived(childFD, data)在您的实施中ProcessProtocol实施。当数据从子进程到达时，这将被回调。请参阅API 文档。

于 2012-06-12T19:17:41.843 回答