twisted.internet._threadedselect.ThreadedSelectReactor : API documentation

def __init__(self): (source)

Undocumented

def wakeUp(self): (source)

Undocumented

def callLater(self, *args, **kw): (source)

Undocumented

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

Add a FileDescriptor for notification of data available to read.

def addWriter(self, writer): (source)

from twisted.internet.interfaces.IReactorFDSet

Add a FileDescriptor for notification of data available to write.

def removeReader(self, reader): (source)

from twisted.internet.interfaces.IReactorFDSet

Remove a Selectable for notification of data available to read.

def removeWriter(self, writer): (source)

from twisted.internet.interfaces.IReactorFDSet

Remove a Selectable for notification of data available to write.

def removeAll(self): (source)

from twisted.internet.interfaces.IReactorFDSet

Remove all readers and writers.

Should not remove reactor internal reactor connections (like a waker).

Returns A list of IReadDescriptor and IWriteDescriptor providers which were removed.

def getReaders(self): (source)

from twisted.internet.interfaces.IReactorFDSet

Return the list of file descriptors currently monitored for input events by the reactor.

Returns the list of file descriptors monitored for input events. (type: list of IReadDescriptor )

def getWriters(self): (source)

from twisted.internet.interfaces.IReactorFDSet

Return the list file descriptors currently monitored for output events by the reactor.

Returns the list of file descriptors monitored for output events. (type: list of IWriteDescriptor )

def stop(self): (source)

overridden in twisted.internet.wxreactor.WxReactor

Extend the base stop implementation to also wake up the select thread so that runUntilCurrent notices the reactor should stop.

def run(self, installSignalHandlers=1): (source)

overridden in twisted.internet.wxreactor.WxReactor

Undocumented

def mainLoop(self): (source)

Undocumented

Method	__init__	Undocumented
Method	wakeUp	Undocumented
Method	callLater	Undocumented
Method	ensureWorkerThread	Undocumented
Method	doThreadIteration	Undocumented
Method	interleave	interleave(waker) interleaves this reactor with the
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	getReaders	Return the list of file descriptors currently monitored for input
Method	getWriters	Return the list file descriptors currently monitored for output events
Method	stop	Extend the base stop implementation to also wake up the select thread so
Method	run	Undocumented
Method	mainLoop	Undocumented
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	_interleave	Undocumented
Method	_mainLoopShutdown	Undocumented
Method	_doReadOrWrite	Undocumented

t.i._.ThreadedSelectReactor(posixbase.PosixReactorBase) : class documentation