Did I find the right examples for you? yes no

All Samples(53)  |  Call(0)  |  Derive(0)  |  Import(53)
twisted.python.threadpool: a pool of threads to which we dispatch tasks.

In most cases you can just use C{reactor.callInThread} and friends
instead of creating a thread pool directly.

src/h/o/hortonworks-sandbox-HEAD/desktop/core/ext-py/Twisted/twisted/web/tap.py   hortonworks-sandbox(Download)
from twisted.web import server, static, twcgi, script, demo, distrib, trp, wsgi
from twisted.internet import interfaces, reactor
from twisted.python import usage, reflect, threadpool
from twisted.spread import pb
from twisted.application import internet, service, strports

src/o/h/oh-mainline-HEAD/vendor/packages/twisted/twisted/web/tap.py   oh-mainline(Download)
from twisted.web import server, static, twcgi, script, demo, distrib, wsgi
from twisted.internet import interfaces, reactor
from twisted.python import usage, reflect, threadpool
from twisted.spread import pb
from twisted.application import internet, service, strports

src/t/w/Twisted-13.2.0/twisted/web/tap.py   Twisted(Download)
from twisted.web import server, static, twcgi, script, demo, distrib, wsgi
from twisted.internet import interfaces, reactor
from twisted.python import usage, reflect, threadpool
from twisted.spread import pb
from twisted.application import internet, service, strports

src/s/u/SubliminalCollaborator-HEAD/libs/twisted/web/tap.py   SubliminalCollaborator(Download)
from twisted.web import server, static, twcgi, script, demo, distrib, wsgi
from twisted.internet import interfaces, reactor
from twisted.python import usage, reflect, threadpool
from twisted.spread import pb
from twisted.application import internet, service, strports

src/u/n/UnitScan-HEAD/twisted/web/tap.py   UnitScan(Download)
from twisted.web import server, static, twcgi, script, demo, distrib, wsgi
from twisted.internet import interfaces, reactor
from twisted.python import usage, reflect, threadpool
from twisted.spread import pb
from twisted.application import internet, service, strports

src/h/o/hortonworks-sandbox-HEAD/desktop/core/ext-py/Twisted/twisted/internet/base.py   hortonworks-sandbox(Download)
        def _initThreadPool(self):
            """
            Create the threadpool accessible with callFromThread.
            """
            from twisted.python import threadpool

src/o/h/oh-mainline-HEAD/vendor/packages/twisted/twisted/internet/base.py   oh-mainline(Download)
        def _initThreadPool(self):
            """
            Create the threadpool accessible with callFromThread.
            """
            from twisted.python import threadpool

src/z/o/zope.app.twisted-3.5.0/src/twisted/trial/util.py   zope.app.twisted(Download)
 
import traceback, gc, sys
from twisted.python import log, threadpool
from twisted.internet import interfaces, utils
 

src/m/y/mythbox-HEAD/resources/lib/twisted/twisted/internet/base.py   mythbox(Download)
        def _initThreadPool(self):
            """
            Create the threadpool accessible with callFromThread.
            """
            from twisted.python import threadpool

src/z/o/zope.app.twisted-3.5.0/src/twisted/internet/base.py   zope.app.twisted(Download)
        def _initThreadPool(self):
            from twisted.python import threadpool
            self.threadpool = threadpool.ThreadPool(0, 10, 'twisted.internet.reactor')
            self.callWhenRunning(self.threadpool.start)
            self.addSystemEventTrigger('during', 'shutdown', self.threadpool.stop)

  1 | 2 | 3 | 4 | 5 | 6  Next