gpt4 book ai didi

python - 从另一个线程扭曲触发事件

转载 作者:行者123 更新时间:2023-11-28 17:51:49 25 4
gpt4 key购买 nike

我有一个应用程序,为方便起见(我正在重用现有代码)已分为两个不同的线程:

  • 运行扭曲 react 器的一个线程
  • 运行交互式菜单的另一个线程

我想从交互式菜单中执行的其中一件事是与 react 堆进行交互。一旦用户给出了特定的命令,我想触发一个扭曲的事件。这是我的代码的一个非常简化的版本:

from   twisted.spread                   import pb
from twisted.internet import reactor
import threading

class TaskGatewaySupport():

def __init__(self):
self.object = None
self.factory = pb.PBClientFactory()
self.connector = None

def gotObject(self, object):
print 'gotObject > %s' % object
self.object = object
return object

def gotData(self, data):
return data

def gotNoObject(self, reason):
print 'gotNoObject > no object: %s' % reason

def connect(self, task_gateway_host = '127.0.0.1', task_gateway_pb_port = 8889):
print 'Connecting to %s:%s' % (task_gateway_host, task_gateway_pb_port)
self.connector=reactor.connectTCP(task_gateway_host, task_gateway_pb_port, self.factory)
d = self.factory.getRootObject()
d.addCallbacks(self.gotObject, self.gotNoObject)
return d

def Menu(task_gateway_support):
while True:
print '''

A) Connect

'''
choice = raw_input('Option > ')
if choice == 'A' : task_gateway_support.connect()
else : print "ERR: command not yet supported"

def version1():
task_gateway_support = TaskGatewaySupport()
thread = threading.Thread(target = Menu, args = (task_gateway_support,))
thread.start()
reactor.run()

def version2():
task_gateway_support = TaskGatewaySupport()
d = task_gateway_support.connect()
reactor.run()

if __name__ == '__main__':
version1()

如您所见,我展示了两个不同的版本:

  • 版本 1 是我想要运行的版本,但它没有
  • 版本2只有一个线程,没有交互

运行 version2 会得到这个结果:

Connecting to 127.0.0.1:8889
gotObject > <twisted.spread.pb.RemoteReference instance at 0x88e734c>

这是我所期待的。

运行 version1 会得到这个:

        A) Connect


Option > A
Connecting to 127.0.0.1:8889


A) Connect


Option > ^CgotNoObject > no object: [Failure instance: Traceback (failure with no frames): <class 'twisted.internet.error.ConnectError'>: An error occurred while connecting: [Failure instance: Traceback (failure with no frames): <class 'twisted.internet.error.ConnectionLost'>: Connection to the other side was lost in a non-clean fashion: Connection lost.
].
]

我在这里所做的是选择选项 A,由于没有任何反应,我按 ^C,这会显示错误消息。

我认为问题的出现是因为我在两个不同的线程中共享一个对象,并且我试图从非扭曲线程触发扭曲事件。我希望,由于该对象是共享的,因此 react 堆会知道该对象发生的任何事情。

所以我的主要问题是:如何从另一个线程触发扭曲事件?

最佳答案

你应该避免为此使用线程。参见 User interaction in twisted process有关如何在单个线程中接受用户输入的信息。

除此之外,使用 reactor.callFromThread任何时候你想从非 react 器线程调用任何 Twisted API。

关于python - 从另一个线程扭曲触发事件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8532131/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com