我正在尝试制作一个 Python 库以使用来自 Objective-C 的 Ubutu One API。这是我的源代码: https://github.com/JoseExposito/U1-Finder-Plugin/blob/master/U1FinderLib/U1FinderLib.py

我需要对 API 进行多次调用，因此我需要让我的 react 器运行一次而不是运行它然后停止它，就像 Ubuntu One 文档的示例中那样: https://one.ubuntu.com/developer/files/store_files/syncdaemontool

因为不可能运行两次 react 堆...而且我需要在线程中执行 reactor.run() 因为我不能阻止使用该库的应用程序!

这有可能吗？我无法在线程中运行 react 器并同步调用 Ubuntu One API。

编辑:

我正在使用这个简单的源代码来测试这个想法:

#!/usr/bin/env python
import objc
import thread
import os
import time
from   twisted.internet import reactor, defer
from   ubuntuone.platform.tools import (SyncDaemonTool, is_already_running)
from   threading import Thread
NSObject = objc.lookUpClass('NSObject')

##
# Variable to get the result of the calls to the Sync Daemon.
# The result is a JSON string stored in returned_value[0].
returned_value = ['']

##
# Objective-C facade to the methods of the U1FinderLib.
class U1FinderLib(NSObject):

    def init(self):
        self = super(U1FinderLib, self).init()
        self.sync_daemon_tool = SyncDaemonTool(None)
        Thread(target=reactor.run, args=(False,)).start()
        return self

    @objc.typedSelector('@@:')
    def volumeList(self):
        print "Begin volumeList"
        reactor.callLater(0, run_command, "volume_list", [], self.sync_daemon_tool)
        print "End volumeList"
        return returned_value[0]

##
# Auxiliar functions to call to the sync daemon.
@defer.inlineCallbacks
def run_command(action, params, sync_daemon_tool):
    print "run_command"
    running = yield is_already_running()
    print "After is_already_running"
    try:
        if not running:
            returned_value[0] = '{ type:"error" reason:"Sync Daemon is not running" }'
        else:
            print "Before run_action"
            yield run_action(action, params, sync_daemon_tool)
            print "After run_action"
    except Exception, e:
        returned_value[0] = '{ type:"error" reason:"Exception: %s" }' % e

@defer.inlineCallbacks
def run_action(action, params, sync_daemon_tool):
    if action == "volume_list":
        d = sync_daemon_tool.get_folders()
        returned_value[0] = yield d.addCallback(lambda r: volume_list(r))

# Volume List
def volume_list(folders):
    volumes_json = '{ type:"volume_list" volumes: { \n\t{ volume:"' + os.path.expanduser('~/Ubuntu One') + '" subscribed:"YES" }'
    for folder in folders:
        volumes_json += ',\n\t{ volume:"' + folder['path'] + '" subscribed:"' + ('YES' if bool(folder['subscribed']) else 'NO') + '" }'
    volumes_json += '\n} }'
    return volumes_json

if __name__ == '__main__':
    py = U1FinderLib.alloc().init()
    print py.volumeList()
    print "EXIT"

这是程序的输出:

Begin volumeList
End volumeList

EXIT

问题是“run_command”函数从未被调用

最佳答案

与其在线程中运行 react 器，不如使用与要在其中使用它的应用程序集成的 react 器。

例如，您可能想使用 CoreFoundation reactor (因为您的应用程序使用 Obj-C 并且名称中包含“Finder”)。

如果你真的做不到(例如，如果 Ubuntu One 需要一个不同的 react 器——我不知道是否是这种情况)，那么你可能可以在一个线程中运行那个 react 器。大多数 react 器都支持这一点，但如果 Ubuntu One 需要特定的 react 器，则该 react 器可能不支持线程使用。

您实际上并没有解释尝试在线程中运行 react 器时遇到的问题，所以我无法帮助您理解为什么它不起作用。但是，这样做应该很容易。只是:

from twisted.internet import reactor
from threading import Thread

Thread(target=reactor.run, args=(False,)).start()

请记住，一旦您选择在一个线程中运行 react 堆，您可以仅在那个线程中使用 Twisted API。

如果这不起作用，请在您的问题中提供有关它为何不起作用的更多详细信息。

关于python - 在线程中执行 Twisted reactor.run()？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/14274916/