1

这个小龙卷风测试有以下问题：

class SimpleIOLoopTests(tornado.testing.AsyncTestCase):
    def setUp(self):
        super(SimpleIOLoopTests, self).setUp()

    def test_executor_future(self):
        self.executor = ThreadPoolExecutor(2)

        @run_on_executor
        def wait_and_return_a_value():
            time.sleep(2)
            return 20

        @coroutine
        def async_compare(callback):
            val = yield wait_and_return_a_value()
            assert_that(val, equal_to(20))

            callback()

        async_compare(self.stop)
        self.wait()

关键是测试只是循环直到发生超时。调试代码看起来好像 executor-future 是作为 done() 创建的，因此甚至没有由 io_loop 启动。

我在这里做错了什么？非常感谢您对此问题的帮助

顺便说一句：如果我使用像这样的@return_future 装饰器创建一个微不足道的未来，也会发生同样的情况（对于它，它已经完成了偶然的事实）

@return_future
    def get_value(callback):
        callback(10)

谢谢和问候马库斯

4

1 回答 1

2

问题是执行器必须“存在”在定义了 io_loop 和执行器的类中（这可以在您检查 @run_on_executor 装饰器时看到）。

def test_executor_future(self):
    class Executor():
        def __init__(self, io_loop=None):
            self.io_loop = io_loop or IOLoop.instance()
            self.executor = ThreadPoolExecutor(2)

        @tornado.concurrent.run_on_executor
        def wait_and_return_a_value(self):
            return 20

        def destroy(self):
            self.executor.shutdown(1)

    @tornado.gen.coroutine
    def async_compare(callback):
        executor = Executor()
        val = yield executor.wait_and_return_a_value()
        assert_that(val, equal_to(20))

        executor.destroy()
        callback()

    async_compare(self.stop)
    self.wait()
于 2013-06-03T06:35:14.280 回答