Python Twisted 中 LoopingCall 和 callInThread 的区别
Python Twisted 是一个基于事件驱动的网络编程框架，它提供了一种异步的编程模型。在 Twisted 中，LoopingCall 和 callInThread 都是用于调度任务的方法，但它们有一些区别。
- LoopingCall：
- 概念：LoopingCall 是 Twisted 中的一个类，用于循环调用指定的函数或方法。
- 分类：LoopingCall 属于 Twisted 的定时器类。
- 优势：LoopingCall 可以按照指定的时间间隔循环调用函数或方法，可以实现周期性的任务调度。
- 应用场景：适用于需要定时执行某个函数或方法的场景，比如定时发送心跳包、定时更新缓存等。
- 推荐的腾讯云相关产品：腾讯云函数（SCF）。
- 产品介绍链接地址：https://cloud.tencent.com/product/scf
- callInThread：
- 概念：callInThread 是 Twisted 中的一个函数，用于在新线程中调用指定的函数或方法。
- 分类：callInThread 属于 Twisted 的线程调度函数。
- 优势：callInThread 可以在新线程中执行函数或方法，避免阻塞主线程，适用于需要在后台执行耗时操作的场景。
- 应用场景：适用于需要在后台执行耗时操作的场景，比如网络请求、文件读写等。
- 推荐的腾讯云相关产品：腾讯云容器服务（TKE）。
- 产品介绍链接地址：https://cloud.tencent.com/product/tke
总结：
LoopingCall 和 callInThread 都是 Twisted 中用于调度任务的方法，但 LoopingCall 适用于定时执行函数或方法的场景，而 callInThread 适用于在新线程中执行函数或方法的场景。在使用时，可以根据具体需求选择合适的方法来实现任务调度。
相关·内容
我的密码
from twisted.internet import task, reactor
def stuff():
print('Hello, world!')
scheduler = task.LoopingCall(stuff())
scheduler.start(10)
reactor.run()
这就是我要犯的错误
你好，世界！递延中未处理的错误：
回溯(最近一次调用)：文件"C:\Users\Usama fiaz\AppData\Local\Programs\Python\Python39\lib\site-packages\twisted
浏览 11提问于2022-05-25得票数 1
1回答
我有一个扭曲的，我从开始。我如何开始一个任务，这是一个功能的工厂？我试过：
if __name__ == "__main__":
factory = MyFactory()
reactor.listenTCP(555558, factory)
reactor.connectTCP("127.0.0.1", 55555, MyConnector(factory))
sanitizing = task.LoopingCall(factory.sanitize())
sanitizing.start(3, False)
浏览 1提问于2014-09-02得票数 0
回答已采纳
我正在编写一个Python程序，由一个服务器(使用Twisted)和一个客户端(不使用Twisted)组成
服务器部分使用Twisted和Twisted的实现，并使用Twistd启动以进行守护。
在不同服务器上运行的客户端是一个简单的Python脚本，没有任何Twisted的东西(也没有特定于应用程序框架的东西)。它也应该作为守护进程运行。仅供参考，这是来源：
#!/usr/bin/env python
# -*- coding: utf-8 -*-
import socket
import sys
import time
import syslog
SERVER_IP = '127
浏览 3提问于2011-09-09得票数 1
回答已采纳
1回答
我在我的实时项目中使用python twisted。
解释:我正在给我的远程machine.So请求的url的html页面，我在我的数据库机器中维护调度器，它发送请求到远程机器，并通过张贴url参数异步获取结果。
因此，在twisted中，我每两分钟运行一次"LoopingCall服务“中的main方法，无论我们得到的结果是成功回调链还是错误回调链。
在这个场景中，当一个请求到达back.The失败时，我得到了错误，其他远程机器仍然可以用于service.So，在这里，无论发生什么情况，我的main方法都应该每两个minutes.It调用一次，因为一些中断的错误。
from
浏览 0提问于2013-01-04得票数 2
2回答
为什么我在实现LoopingCall函数调用AMP命令时出错？
from twisted.protocols.amp import AMP
from twisted.python.log import startLogging, err
from twisted.internet.task import LoopingCall
from twisted.internet import reactor
from sys import stdout
import commands
startLogging(stdout)
class MyAMP:
def __init__(sel
浏览 2提问于2013-08-16得票数 2
回答已采纳
我的服务器设置为每100 is对所有客户机进行勾选和更新--参见self.TICKS_PER_SECOND = 10，1000/10 =100 is。
但是，html中的“时钟”每1秒才会更新一次。为什么？
如果我继续点击提交按钮，比时钟更新得更快。为什么？
app.py
import logging
import sys
from datetime import datetime
import time
current_milli_time = lambda: int(round(time.time() * 1000))
import json
import threading
from
浏览 2提问于2017-01-22得票数 0
回答已采纳
目标:在客户端的wxPython图形用户界面中显示来自服务器的数据
Twisted的新手。我在Windows7客户端上运行了Ubuntu，在wxPython服务器上运行了一个生成日志的程序。我当前的尝试是对日志进行-f，将输出通过管道传输到一个扭曲的服务器，然后将满足正则表达式条件的任何数据提供给客户机。我已经打开了一个通道，所以我不需要使用SSH来使事情复杂化。我已经运行了下面的代码块，但它只服务于输入中的第一行。我知道我需要不断检查输入中的换行符，然后将其写入传输，但我不确定如何在不中断连接的情况下做到这一点。
我还没有找到足够的信息来拼凑一个完整的解决方案。我还尝试了使用套接字和文件IO
浏览 1提问于2011-11-17得票数 9
回答已采纳
1回答
我有一个基本的IRC机器人，看起来像这样(见下文)，我想做的是使用类似于_5_mins函数的东西，每5分钟用一个LoopingCall调用一次
import sys
import re
from twisted.internet import reactor, task, defer, protocol
from twisted.python import log
from twisted.words.protocols import irc
from twisted.application import internet, service
import time
HOST, PORT =
浏览 0提问于2012-11-30得票数 3
回答已采纳
下面是代码的框架：
from twisted.internet import reactor
from twisted.internet.task import LoopingCall
def do_something():
print "Doing something..."
def process_result():
print "Processing result..."
def loop():
LoopingCall(do_something).start(1)
reactor.callWhenRunning(loop)
浏览 2提问于2017-07-07得票数 4
回答已采纳
我正在尝试弄清楚Twisted中task.LoopingCall和reactor.callInThread之间的区别。
我在LoopingCall中的所有self.sendLine操作都会立即执行。callInThread中的不是。它们只在LoopingCall中的那个完成之后才会发送。即使我发送的是正确的分隔符。
为什么会这样呢？有什么关系呢？它们不都是线程吗？
这是服务器：
from twisted.internet import reactor, protocol, task
from twisted.protocols import basic
from twisted.python
浏览 1提问于2010-07-11得票数 1
回答已采纳
我的基于Twisted的客户端在循环中发送UDP数据包。因此，我使用DatagramProtocol类。这是来源：
#!/usr/bin/python
# -*- coding: utf-8 -*-
from twisted.application.service import Service
from twisted.internet import reactor
from twisted.internet.task import LoopingCall
from twisted.internet.protocol import DatagramProtocol
from twisted.p
浏览 0提问于2011-09-12得票数 3
回答已采纳
我将从我不是python程序员开始。我为我的IRC频道修改了一个扭曲的机器人。我现在正在尝试集成第二个线程，这样我就可以在不中断正常IRC命令的情况下，每30分钟在该频道上获得twitter更新。
我已经测试了twitter的更新代码，它工作正常……但我不确定如何将其添加到机器人的类和函数中，并使用twisted的框架发送消息。
这是twitter更新的代码块：
# For Twitter feed
from twitter import *
from thread import start_new_thread
from datetime import datetime, timedelta
浏览 0提问于2015-01-08得票数 2
我尝试使用txredis (适用于redis的非阻塞扭曲api )创建持久化消息队列，但没有成功，我正在处理一个scrapy项目。我发现，尽管客户端没有阻塞，但它变得比本来可以慢得多，因为在反应器循环中本应是一个事件的东西被分成了数千个步骤。
因此，我尝试使用redis-py (常规的阻塞扭曲api)并将调用包装在延迟线程中。它工作得很好，但是当我调用redis时，我想执行内部延迟，因为我想设置连接池，试图进一步加快速度。
下面是我对一些示例代码的解释，这些代码取自用于延迟线程的扭曲文档，以说明我的用例：
#!/usr/bin/env python
from twisted.internet
浏览 2提问于2010-03-18得票数 7
回答已采纳
1回答
我正在尝试使用p2exe从使用pymodbus和twisted (显然有很多底层依赖项)的python脚本构建一个exe。我可以构建exe，但它不能正常运行。我正在试图找出我在设置环境时做错了什么。我确信这不是我的脚本，因为我可以从python命令行解释器中很好地运行它。
我的python脚本使用了这些模块...
from pymodbus.server.async import StartTcpServer
from pymodbus.datastore import ModbusSequentialDataBlock
from pymodbus.datastore import Modbu
浏览 0提问于2015-02-13得票数 1
2回答
我想在Python中使用一个单独的threadPool，用于一些特殊的工作，这对CPU的使用是很困难的。
我想要执行的函数都被定义为inlineCallback，我不能修改它。
from twisted.python.threadpool import ThreadPool
@inflineCallbacks
def myFunc(i):
tmp_result = yield intenseCPUwork(i)
# more work ...
return result
pool = ThreadPool(0, 2)
for i in range(100):
浏览 1提问于2021-01-17得票数 0
回答已采纳
更新我正在使用Twisted 22.4.0和Python3.9.6
我试图编写一个异步应用程序，它必须以250 at的频率运行一个事件循环。到目前为止，Twisted还不够快，无法为我的应用程序工作(但我想知道是否有可能修复这个问题)。在Windows 10 i5笔记本电脑上，我在LoopingCall中可以达到的最高频率是50 is左右。当我调整以下代码在50赫兹运行正常，并成功地打印出“花费了1.002秒”，但在100赫兹时，代码通常需要1.5秒才能运行，我需要我的代码能够在.004 (250 be )下运行。
from twisted.internet.task import Loopi
浏览 17提问于2022-06-27得票数 3
回答已采纳
1回答
我有一个工具，在这里我实现upnp发现网络中连接的设备。
为此，我编写了一个脚本，并在其中使用了数据报类。
实现:每当在工具上按下扫描按钮，它就会运行upnp脚本，并将在工具中创建的框中列出设备。
一切都很顺利。
但是，当我再次按下“扫描”按钮时，它会给出以下错误：
Traceback (most recent call last):
File "tool\ui\main.py", line 508, in updateDevices
upnp_script.main("server", localHostAddress)
File "t
浏览 2提问于2014-05-12得票数 2
1回答
我有一个这样的代码：
from twisted.internet import task
from twisted.internet import reactor
def Fun1():
print('No')
communicate1 = task.LoopingCall(Fun1)
communicate1.start(0.1)
reactor.run()
while True:
print('yes')
time.sleep(1)
它不应该同时运行Func1和while循环吗？它有什么问题？它只打印No。
浏览 4提问于2018-08-08得票数 0
我使用Twisted，每隔x秒进行一次循环调用。
我用于循环调用的函数会生成一个return语句。
def f():
# Obtain stuff
return stuff
def main():
LoopingCall(f).start(x)
如何检索f的返回结果？
谢谢!
浏览 0提问于2015-12-03得票数 1
2回答
我正在用Twisted编写一个web服务器。此服务器执行的任务之一需要很长时间(~5分钟)。我希望能够有效地通知客户端这个任务已经完成。
我已经研究过使用Comet/long轮询，但在我的生命中，我无法让浏览器在收到数据时呈现数据。
为了实现该机制的原型，我编写了以下内容：
clock.py
from twisted.internet import reactor, task
from twisted.web.static import File
from twisted.web.server import Site
from twisted.web import server
from tw
浏览 4提问于2011-05-07得票数 3
我有一个简单的例子：
from twisted.internet import utils, reactor
from twisted.internet import defer
from twisted.internet import threads
from twisted.internet.task import LoopingCall,deferLater
import time
def test1():
print 'test'
def test2(res):
l = []
for i in xrange(3):
浏览 1提问于2011-08-28得票数 3
回答已采纳
如何更改此代码，以便每隔60秒调用一次doWork()。目前，它正在肯定地循环，并在60秒后停止。想要做完全相反的事情。
from twisted.internet import task
from twisted.internet import reactor
import twapi
timeout = 200.0 # Sixty seconds
def doWork():
#do work here
twapi.main('1')
pass
l = task.LoopingCall(doWork)
l.start(timeout) # call
浏览 0提问于2012-05-20得票数 1
回答已采纳
1回答
我从OpenCV VideoCapture.read()获取视频帧，并将该帧发送到 WebSocket 服务器( Twisted with Autobahn WebSocket API)，我还使用Twisted IPushProducer接口将数据流到WebSocket，并最终在发送回客户端时清理摄像机。
这是我的密码。
server.py
import cv2
import cv2.cv as cv
import numpy as np
from autobahn.twisted.websocket import WebSocketServerProtocol, \
浏览 2提问于2014-05-06得票数 1
如果Scrapy在例外情况下失败，应该采取什么明智的行动：
OSError: Errno 28设备上没有空间
Traceback (most recent call last):
File "/usr/lib/python3.6/site-packages/twisted/internet/defer.py", line 1386, in _inlineCallbacks
result = g.send(result)
File "/usr/lib/python3.6/site-packages/scrapy/core/downloader/mi
浏览 0提问于2018-03-31得票数 0
回答已采纳
我试图编辑键盘IO示例，以便在实时绘图发生时输入命令并更改所绘制的内容。我有以下简单的代码。
import random, pylab, threading, signal, time
from twisted.internet import stdio
from twisted.protocols import basic
from twisted.internet import reactor
# Start interactive mode
pylab.ion()
# Initialize lock semaphore
lock = threading.Lock()
line, =
浏览 2提问于2014-04-15得票数 0
回答已采纳
我想要创建一个服务器和客户端，它使用Twisted从网络发送和接收UDP数据包。我已经用Python中的套接字编写了这篇文章，但是我想利用Twisted的回调和线程特性。不过，我需要帮助，虽然设计的扭曲。
我想接收多种类型的数据包，但让我们假设只有一个：
class Packet(object):
def __init__(self, data=None):
self.packet_type = 1
self.payload = ''
self.structure = '!H6s'
if d
浏览 1提问于2010-09-03得票数 6
回答已采纳
1回答
Comet连接超时
、、、、
我有一个用Twisted编写的简单的comet服务器。它打印出时间戳。我还有一个运行在同一端口上的小型静态the服务器。所服务的页面上的javascript试图通过附加来自comet服务器的时间戳来更新页面。
但是没有显示来自comet服务器的任何内容。使用Chromium中的开发人员工具，我可以看到打开了一个长连接。但是连接超时，并且不会向页面追加任何内容。为什么不动呢？
下面是一个自包含的示例：
from twisted.internet import reactor
from twisted.internet import task
from twisted.web import ser
浏览 6提问于2011-12-15得票数 1
回答已采纳
我想用Python构建一个节拍器。
我有两个声音文件。每隔一秒播放第一个声音文件，每隔四秒钟播放第二个声音文件。
我找到了扭曲的模块，但不知道如何传递参数和迭代它。所以我有一个我想要迭代的变量counter，但它不能在以下代码中工作：
import simpleaudio as sa
from twisted.internet import task
from twisted.internet import reactor
def beat(bpm, counter):
timeout = 60/bpm
l = task.LoopingCall(play_beat, cou
浏览 33提问于2018-05-09得票数 0
我试图在Python中重新实现netcat：
#!/usr/bin/env python2
from sys import stdin, stdout
from twisted.internet import reactor
from twisted.internet.protocol import Protocol
from twisted.internet.endpoints import TCP4ClientEndpoint, connectProtocol
class NcClient(Protocol):
def dataReceived(self, data):
浏览 4提问于2015-11-13得票数 2
我正在尝试用Twisted编写一个长轮询服务器，但我恐怕不理解请求管理。
当客户端离开页面时，我可以看到它继续在控制台中循环。我认为当客户端断开连接时，实例会自行销毁。
这就是我的目标，我希望在DataService中为每个连接的客户端单独运行逻辑。
这是我所拥有的：(为了方便使用，我把这段代码砍掉了，可能会因此出现一些语法错误，但它来自于工作代码)
class DataService(Resource):
def __init__(self, sid):
# set looping call
self.loopingCall = task.Loopin
浏览 0提问于2011-12-08得票数 1
回答已采纳
经过大量的调查，我发现在为成千上万的HTTP请求提供服务之后，出现了内存泄漏。奇怪的是，内存泄漏仅在使用PyPy时发生。
下面是一个示例代码：
from twisted.internet import reactor
import tornado.ioloop
do_tornado = False
port = 8888
if do_tornado:
from tornado.web import RequestHandler, Application
else:
from cyclone.web import RequestHandler, Application
cl
浏览 4提问于2014-01-11得票数 4
回答已采纳
我开始查看服务器发送的事件，并开始对使用我喜欢的工具Python、Flask和Twisted进行尝试感兴趣。我要问的是，与gevent的greenlet.sleep方式相比，睡觉的方式是否合适，这是我非常简单的代码，并将其“移植”到Twisted (从gevent)：
#!/usr/bin/env python
import random
from twisted.web.server import Site
from twisted.web.wsgi import WSGIResource
from twisted.internet import reactor
import time
浏览 1提问于2013-12-04得票数 7
回答已采纳
扭曲的文档提供了一个示例
下面是我目前拥有的代码(源自上述示例)：
from twisted.words.protocols import irc
from twisted.internet import protocol
from twisted.internet import reactor
class Bot(irc.IRCClient):
def _get_nickname(self):
return self.factory.nickname
nickname = property(_get_nickname)
def signedOn(s
浏览 3提问于2012-11-29得票数 1
2回答
我开始学习Twisted，并试图完成我的第一项任务。我有下一个服务器代码：
class TextProtocol(Protocol):
def connectionMade(self):
text = self.factory.text
self.transport.write(text)
self.transport.loseConnection()
class TextServerFactory(ServerFactory):
protocol = TextProtocol
def __init__(self,
浏览 2提问于2014-04-28得票数 0
回答已采纳
2回答
如何重启Scrapy蜘蛛
、、、
我需要的是：
起动履带器
履带作业完成
等1分钟
再次启动爬行器
我试试看：
from scrapy.crawler import CrawlerProcess
from scrapy.utils.project import get_project_settings
from time import sleep
while True:
process = CrawlerProcess(get_project_settings())
process.crawl('spider_name')
process.start()
浏览 5提问于2017-02-19得票数 9
我有一个简单的代码来测试Twisted.internet模块是如何工作的。当发生某种情况时，我试图停止循环(例如:当我等于5时)，但我无法运行它。我有两个主要错误：
1.
exceptions.UnboundLocalError: local variable 'i' referenced before assignment
如果我只是在没有If语句的情况下在末尾添加reactor.stop()，循环就不会停止，为什么？
from twisted.internet import task
from twisted.internet import reactor
time =
浏览 1提问于2014-10-20得票数 2
回答已采纳
1回答
我正在尝试创建客户端应用程序(使用扭曲)，它将发送一些数据(总是相同的)到服务器。我需要这个来检查服务器上的操作状态。但是我不知道如何使用Twisted来做这件事。
from twisted.internet.protocol import Protocol, ClientFactory
from twisted.internet import task
from sys import stdout
from twisted.internet import reactor
host = 'localhost'
port = 8007
class InstProtocol(P
浏览 3提问于2015-08-07得票数 0
我正在编写一个简单的服务器程序。它们是新代码中不可避免的输入错误和其他错误，而且python解释器通常会打印ValueError/AttributeError回溯和退出。回溯可以指向错误的确切位置。然而，在扭曲的框架下，这些错误不会被打印出来。如以下示例所示：
from twisted.internet import reactor, protocol, task
#from twisted.internet.defer import setDebugging
#setDebugging(True)
class MyProtocol(protocol.Protocol):
def d
浏览 2提问于2017-04-23得票数 0
回答已采纳
1回答
在我的代码中，我使用task.LoopingCall()每秒运行一些延迟函数。我希望确保该函数返回特定数量的正确值。因此，我认为可以使用task.clock()并对其调用advance()方法。然而，我没有得到预期的正确数量的回复。
你知道我做错了什么吗？
下面是一段测试代码，用来说明我的意思。首先是服务器：
from twisted.internet.protocol import Factory
from twisted.protocols.basic import LineReceiver
from twisted.internet import reactor
from twisted
浏览 0提问于2013-01-31得票数 3
回答已采纳
这里的文档表明，不同之处在于cooperate返回一个CooperativeTask，而coiterate返回一个Deferred (我自己的测试证明了这一点，文档中没有指定)。我花了一个周末的时间学习Twisted的基础知识，所以我知道什么是延迟，并且我一直是个好孩子，把我的阻塞代码发送到线程/进程。我知道coiterate在Twisted允许的范围内运行得尽可能快，而LoopingCall则尝试在选定的时间间隔内触发。
我的直觉是coiterate()任务是在CooperativeTask对象中完成的，而coiterate()任务是在延迟对象中完成的。如果有人能总结出it和coiterat
浏览 0提问于2012-04-10得票数 9
回答已采纳
因此，我的问题在标题中，下面两段代码是我对此的尝试。我试图在脚本启动后立即分配一个变量，然后在一定的时间间隔内运行循环定义并更新相同的变量。我不想用全局的。
from twisted.internet import task, reactor
class DudeWheresMyCar(object):
counter = 20
stringInit = 'initialized string'
def loop():
stringNew = 'this will be updated with a changing stri
浏览 3提问于2016-09-21得票数 0
回答已采纳
1回答
我试图弄清楚Gevent与python中的其他异步框架(如Twisted )是如何工作的。
Gevent和Twisted之间的关键区别在于Gevent使用了用于隐式行为和同步编程模型的标准库补丁，而Twisted则需要特定的库和显式行为的回调。Gevent中的事件循环是libev/libevent，用C编写，Twisted中的事件循环是用python编写的反应器。
libev/libevent有什么特别的地方允许这种隐式行为吗？为什么不使用用Python编写的事件循环呢？相反，为什么不使用libev/libevent来扭曲？有什么特别的原因吗？也许这只是一个设计上的选择，可以走任何一条路.
理
浏览 3提问于2016-06-04得票数 2
我正在继承ReconnectingClientFactory并使用SSL连接。我们已经将其全部运行，但几分钟后我收到以下错误。一旦发生此错误，连接就会丢失
Unhandled Error
Traceback (most recent call last):
File "/usr/local/hikvision/ezops/python/lib/python2.7/site-packages/twisted/python/log.py", line 103, in callWithLogger
return callWithContext({"system&#
浏览 14提问于2017-02-15得票数 0
回答已采纳
我试图制作这个简单的服务器脚本，其中多个客户端连接到它，并存储在factory.connected_clients字典中。然后，我想显示一个菜单，这样执行服务器的用户就可以选择他想要使用的客户端，以及他想发送哪些命令(就像在反向shell中)。下面是代码：
class RshServer(protocol.Protocol):
def __init__(self, factory, addr):
self.addr = addr
self.factory = factory
def connectionMade(self):
浏览 3提问于2015-06-27得票数 2
回答已采纳
1回答
我正在尝试运行一个带有pygame客户端的扭曲服务器：
class ChatClientProtocol(LineReceiver):
def lineReceived(self,line):
print (line)
class ChatClient(ClientFactory):
def __init__(self):
self.protocol = ChatClientProtocol
def main():
flag = 0
default_screen()
while True:
for ev
浏览 0提问于2012-09-12得票数 6
回答已采纳
我试着用twisted写一个小服务。
我创建了一个简单的应用程序，并尝试添加2个ILogObservers到我的服务。但不幸的是，它不起作用。最后添加的观察者始终是要使用的观察者。
def log(eventDict):
...
def mylog(eventDict):
...
LoopingCall(logSomething).start(1)
application = Application("twistd-logging")
application.setComponent(ILogObserver, log)
application.setComponent(
浏览 1提问于2011-08-31得票数 1
2回答
考虑到我在Twisted中与DatagramProtocol实现了UDP客户机，并使用它与UDP服务器进行通信，UDP服务器一度脱机(因为重新启动--因此它不会更改它的IP地址)，则调用我的协议中的stopProtocol，但是Twisted将传输本身设置为None。
如何在Twisted中解决简单的重新连接或重新启动传输？根据文档，我无法再次与udp连接。
考虑到在UDP中，发送方应该能够在服务器死后发送数据包，并且该协议在数据包中有自己的连接处理，如果传输不会消失，我可以完全通过数据包层重新连接逻辑部分。
我认为在核心运行时使用新协议再次运行listenUDP是行不通的。
from twi
浏览 1提问于2014-02-10得票数 1
回答已采纳
1回答
这个问题选得不好，我再试一次。
我有一个纯粹是为了学习网络游戏而准备的。
我对twisted的理解是，我应该让一个服务器类运行反应器，然后让每个玩家作为客户端连接到它(服务器是一个单独的实体)。考虑到我上一个问题中的评论，我怀疑我以完全错误的方式来处理这个问题。
我应该做什么，我应该关注哪些教程或文档？
浏览 0提问于2011-12-05得票数 3
回答已采纳
我无法处理ConnectionLost异常。我所拥有的简单例子。首先，iIset将连接到jabber服务器并对其进行ping。我用的是wokkel图书馆。然后将errback添加到发送ping的方法中。在回错中，我处理ConnectionLost错误。在那之后，我关闭了互联网连接。但我看不出这个ConnectionLost是否被处理了。我关闭应用程序中的连接，并调用所有异常处理程序。
平做得很好。
[XmlStream,client] Ping to JID(u'jabber.ru') started at HivemindPingClientProtocol
[-] SEN
浏览 0提问于2011-01-31得票数 4
1回答
让我们假设我们有一个黑盒生成器，它是完全阻塞的，并且永远运行。我们正在运行Twisted，所以处理阻塞问题的标准方法是使用defers或defers + threads。
# some very naive example
from twisted.internet import reactor
def aSillyBlockingMethod():
for results in fullblocking_blockbox_generator_that_runs_forever():
print results
reactor.callInThread(aSilly
浏览 9提问于2016-09-15得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
