1

私はツイストで遊んでいて、単体テストのリストをスレーブに配布する単純なマスターサーバーを作成しようとしています。次のコードは機能しますが、私の出力は奇妙です。n 個のテストのそれぞれを実行する代わりに、スレーブは最後の単体テストを n 回実行しています。

私はツイストのビルトインアンププロトコルを使用しています。関連するコードは次のとおりです。

class Master(object):

    def __init__(self):
        self.tests = [
            "test1",
            "tests2",
            ... etc
        ]

    def serve(self):
        self.factory = MasterFactory()
        reactor.listenTCP(1234, self.factory)
        d = threads.deferToThread(self.get_cmd)
        d.addCallback(lambda ign: self.run_test())
        print 'Serving on port 1234'

    def get_cmd(self):
        return raw_input('> ')

    def run_test(self):
        while True:
            for slave in self.factory.slaves.values():
                if self.tests == []:
                    break
                slave.tests.append(self.tests.pop(0))
            if self.tests == []:
                break

        for slave in self.factory.slaves.values():
            self.construct_list(slave)

    def construct_list(self, slave):
        d = defer.Deferred()
        for test in slave.tests:
            d.addCallback(lambda ign:
                slave.protocol.callRemote(commands.RunCmd, cmd="python setup.py trial -s " + test))
            d.addCallback(self.cmd_response)
        d.callback(None)

    def cmd_response(self, response):
        print response['output']
        return None


def main():
    m = Master()
    m.serve()
    reactor.run()

if __name__ == "__main__":
    main()
4

1 に答える 1

3

これは、ループ変数とクロージャが Python でどのように機能するかについてよくある落とし穴です。次の例を検討してください。

>>> def f(n):
...     print n
... 
>>> fs = []
>>> for i in range(3):
...     fs.append(lambda: f(i))
... 
>>> fs[0]()
2
>>> fs[1]()
2
>>> fs[2]()
2
>>>
于 2013-08-05T01:25:53.110 に答える