Class t.i._.ThreadedSelectReactor(posixbase.PosixReactorBase):

Part of twisted.internet._threadedselect View Source View In Hierarchy

Known subclasses: twisted.internet.wxreactor.WxReactor

Implements interfaces: twisted.internet.interfaces.IReactorFDSet
A threaded select() based reactor - runs on all POSIX platforms and on Win32.
Method __init__ Undocumented
Method wakeUp Wake up the event loop.
Method callLater See twisted.internet.interfaces.IReactorTime.callLater.
Method _sendToMain Undocumented
Method _sendToThread Undocumented
Method _preenDescriptorsInThread Undocumented
Method _workerInThread Undocumented
Method _doSelectInThread Run one iteration of the I/O monitor loop.
Method _process_Notify Undocumented
Method _process_Failure Undocumented
Method ensureWorkerThread Undocumented
Method doThreadIteration Undocumented
Method _interleave Undocumented
Method interleave interleave(waker) interleaves this reactor with the
Method _mainLoopShutdown Undocumented
Method _doReadOrWrite Undocumented
Method addReader Add a FileDescriptor for notification of data available to read.
Method addWriter Add a FileDescriptor for notification of data available to write.
Method removeReader Remove a Selectable for notification of data available to read.
Method removeWriter Remove a Selectable for notification of data available to write.
Method removeAll Remove all readers and writers.
Method run Undocumented
Method mainLoop Undocumented

Inherited from PosixReactorBase:

Method _handleSignals Install the signal handlers for the Twisted event loop.
Method _handleSigchld Reap all processes on SIGCHLD.
Method startRunning Undocumented
Method _disconnectSelectable Utility function for disconnecting a selectable.
Method installWaker Install a `waker' to allow threads and signals to wake up the IO thread.
Method _checkProcessArgs Check for valid arguments and environment to spawnProcess.
Method spawnProcess Undocumented
Method listenUDP Connects a given DatagramProtocol to the given numeric UDP port.
Method connectUDP DEPRECATED.
Method listenMulticast Connects a given DatagramProtocol to the given numeric UDP port.
Method connectUNIX
Method listenUNIX
Method listenUNIXDatagram Connects a given DatagramProtocol to the given path.
Method connectUNIXDatagram Connects a ConnectedDatagramProtocol instance to a path.
Method listenTCP
Method connectTCP
Method connectSSL
Method listenSSL
Method listenWith Start an instance of the given portType listening.
Method connectWith Start an instance of the given connectorType connecting.
Method _removeAll Remove all readers and writers, and return list of Selectables.

Inherited from ReactorBase (via PosixReactorBase):

Method installResolver Set the internal resolver to use to for name lookups.
Method doIteration Do one iteration over the readers and writers we know about.
Method resolve Return a Deferred that will resolve a hostname.
Method stop See twisted.internet.interfaces.IReactorCore.stop.
Method crash See twisted.internet.interfaces.IReactorCore.crash.
Method sigInt Handle a SIGINT interrupt.
Method sigBreak Handle a SIGBREAK interrupt.
Method sigTerm Handle a SIGTERM interrupt.
Method disconnectAll Disconnect every reader, and writer in the system.
Method iterate See twisted.internet.interfaces.IReactorCore.iterate.
Method fireSystemEvent See twisted.internet.interfaces.IReactorCore.fireSystemEvent.
Method _cbContinueSystemEvent Undocumented
Method _continueSystemEvent Undocumented
Method addSystemEventTrigger See twisted.internet.interfaces.IReactorCore.addSystemEventTrigger.
Method removeSystemEventTrigger See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger.
Method callWhenRunning See twisted.internet.interfaces.IReactorCore.callWhenRunning.
Method _moveCallLaterSooner Undocumented
Method _cancelCallLater Undocumented
Method cancelCallLater See twisted.internet.interfaces.IReactorTime.cancelCallLater.
Method getDelayedCalls Return all the outstanding delayed calls in the system.
Method _insertNewDelayedCalls Undocumented
Method timeout Undocumented
Method runUntilCurrent Run all pending timed calls.
Method _initThreads Undocumented
Method callFromThread 0 See twisted.internet.interfaces.IReactorThreads.callFromThread.
Method _initThreadPool Undocumented
Method callInThread See twisted.internet.interfaces.IReactorThreads.callInThread.
Method suggestThreadPoolSize See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize.
Method callFromThread Undocumented
def __init__(self): (source)
overrides twisted.internet.posixbase.PosixReactorBase.__init__
Undocumented
def wakeUp(self): (source)
overrides twisted.internet.base.ReactorBase.wakeUp
Wake up the event loop.
def callLater(self, *args, **kw): (source)
from twisted.internet.interfaces.IReactorTime
overrides twisted.internet.base.ReactorBase.callLater
See twisted.internet.interfaces.IReactorTime.callLater.
def _sendToMain(self, msg, *args): (source)
Undocumented
def _sendToThread(self, fn, *args): (source)
Undocumented
def _preenDescriptorsInThread(self): (source)
Undocumented
def _workerInThread(self): (source)
Undocumented
def _doSelectInThread(self, timeout): (source)

Run one iteration of the I/O monitor loop.

This will run all selectables who had input or output readiness waiting for them.
def _process_Notify(self, r, w): (source)
Undocumented
def _process_Failure(self, f): (source)
Undocumented
def ensureWorkerThread(self): (source)
Undocumented
def doThreadIteration(self, timeout): (source)
Undocumented
def _interleave(self): (source)
Undocumented
def interleave(self, waker, *args, **kw): (source)

interleave(waker) interleaves this reactor with the current application by moving the blocking parts of the reactor (select() in this case) to a separate thread. This is typically useful for integration with GUI applications which have their own event loop already running.

See the module docstring for more information.
def _mainLoopShutdown(self): (source)
Undocumented
def _doReadOrWrite(self, selectable, method, dict): (source)
Undocumented
def addReader(self, reader): (source)
from twisted.internet.interfaces.IReactorFDSet
overrides twisted.internet.base.ReactorBase.addReader
Add a FileDescriptor for notification of data available to read.
def addWriter(self, writer): (source)
from twisted.internet.interfaces.IReactorFDSet
overrides twisted.internet.base.ReactorBase.addWriter
Add a FileDescriptor for notification of data available to write.
def removeReader(self, reader): (source)
from twisted.internet.interfaces.IReactorFDSet
overrides twisted.internet.base.ReactorBase.removeReader
Remove a Selectable for notification of data available to read.
def removeWriter(self, writer): (source)
from twisted.internet.interfaces.IReactorFDSet
overrides twisted.internet.base.ReactorBase.removeWriter
Remove a Selectable for notification of data available to write.
def removeAll(self): (source)
from twisted.internet.interfaces.IReactorFDSet
overrides twisted.internet.base.ReactorBase.removeAll

Remove all readers and writers.

Should not remove reactor internal reactor connections (like a waker).
ReturnsA list of IReadDescriptor and IWriteDescriptor providers which were removed.
def run(self, installSignalHandlers=1): (source)
from twisted.internet.interfaces.IReactorCore
overrides twisted.internet.posixbase.PosixReactorBase.run
overridden in twisted.internet.wxreactor.WxReactor
Undocumented
def mainLoop(self): (source)
overrides twisted.internet.posixbase.PosixReactorBase.mainLoop
Undocumented
API Documentation for twisted, generated by pydoctor.