cipher.background 1.0.2

示例

假设我们有一个具有简单发布工作流的管理系统（DMS）。我们有两种状态“草案”和“发布”。在这个示例中的问题是：从“草案”到“发布”的转换需要几分钟时间，我们不希望用户等待。

首先，我们创建一个 WorkflowTransition-BackgroundThread

class MyWorkflowTransition(BackgroundWorkerThread):
    execute = True
    description = "background worker thread (%(class_name)s) for %(site_name)s User %(user_name)s"

    def __init__(self, site_db, site_oid, site_name, user_name, daemon=True, object_oid=None):
        self.object_oid = object_oid
        super(MyWorker, self).__init__(site_db, site_oid, site_name, user_name, daemon=True)

    def scheduleNextWork(self):
        return self.execute

    def getObjectFromOID(self):
        conn = getSite()._p_jar
        return conn.get(self.object_oid)

    def doWork(self):
        sleep(15) # This is our long TASK
        self.execute = False
        document = self.getObjectFromOID()
        document.wf_status = "PUBLISHED"

我们有一个简单的文档，其初始工作流状态为 draft。

class Document(Persistent):
    wf_state = "DRAFT"

现在，我们必须调用我们的 WorkflowTransition。

def setWorkflow(site, document_oid, user_name):
    worker = MyWorkflowTransition(
        site_db = site._p_jar.db(),
        site_oid = site._p_oid,
        site_name = site.__name__,
        user_name = user_name,
        object_oid = document_oid,
        )
    worker.start()

当调用 worker.start() 时，线程进入“后台”，用户不需要等待转换完成。

1.0.2 (2012-07-31)

• 重构 BackgroundWorkerThread 以返回从 getSite() 获取的站点

1.0.1 (2012-04-05)

1.0.0 (2012-02-10)

• 作为独立的包进行初始发布。