thimble 0.2.0

快速开始

您感兴趣的主要对象是thimble.Thimble。它接受一个线程池、一个阻塞对象以及您希望延迟到线程池中的方法名称列表。

这是我们的示例阻塞对象

>>> class Car(object):
...     wheels = 4
...     def drive_to(self, location):
...          # Assume the real implementation blocks.
...          return "driven to {0}".format(location)
>>> car = Car()

出于演示目的，我们将使用线程池和reactor的测试双倍；在实际代码中，您将希望使用真实的东西。

>>> from thimble.test.util import FakeThreadPool, FakeReactor
>>> pool = FakeThreadPool()
>>> reactor = FakeReactor()

池尚未启动。（我们将在下一分钟看到这为什么很重要。）

>>> pool.started
False

创建一个Thimble

>>> from thimble import Thimble
>>> car_thimble = Thimble(reactor, pool, car, ["drive_to"])

当访问列表中的方法时，您将获得一个包装它的对象。调用它返回一个Deferred对象。任何传递的参数都将原样传递给包装的方法。

>>> def print_(s):
...     # can't use from __future__ import print_function because of a
...     # doctest limitation :-(
...     print s

>>> d = car_thimble.drive_to("work").addCallback(print_)
driven to work

由于我们使用的是伪造的线程池和反应器，所以这个Deferred对象已经同步触发。

您可以直接在Thimble上访问包装对象的其它属性。

>>> car.wheels
4

如果传递给Thimble的线程池在第一次尝试使用它之前尚未启动，Thimble将启动它并安排其关闭。如果您传递一个已经启动的线程池，您将负责其关闭。在这种情况下，线程池尚未启动，所以Thimble为您启动了它。

>>> pool.started
True

关闭反应器，反应器将在自身关闭之前要求线程池停止。

>>> reactor.stop()
>>> pool.started
False

from twisted.python.threadpool import ThreadPool
_the_thread_pool = _ThreadPool()

变更日志

Thimble使用SemVer。