threading.currentThread

All Samples(1005) | Call(753) | Derive(0) | Import(252)

No Document.

Show Implementation

        def currentThread():
    try:
        return _active[_get_ident()]
    except KeyError:
        ##print "current_thread(): no current thread for", _get_ident()
        return _DummyThread()

src/p/y/PyZ3950-HEAD/example/twisted/test.py PyZ3950(Download)

 
from PyZ3950 import zoom
 
from threading import Thread, currentThread
from Queue import Queue
 
thread_count = 10

src/s/p/spike-HEAD/vendor/stackless/v2.5.1/Stackless/demo/stephan/stacklessness/stacklessness.py spike(Download)

from threading import Event, currentThread, Lock, Thread
import time
import sys
import logging
from atexit import register
 
__all__ = 'run getcurrent getmain tasklet channel schedule'.split()

    mt = tasklet(None)
    mt._active = True
    mt._name = 'MainTask'
    maintask = currentThread()
    log.info(str(maintask))
    maintask.event = Event()
    mt.thread = maintask

def getcurrent():
    ct = currentThread()
    return ct.tasklet
 
def getmain():
    return maintasklet

    def schedule(self):
        log.info('%s Scheduler.schedule()' % getcurrent())
        log.info('\ttasklist:%s' % self)
        ct = currentThread()
        ctask = ct.tasklet
        log.info('\tcurrent tasklet is: %s' % ctask)
        nt = self.next()

src/s/p/spike-HEAD/vendor/stackless/current/Stackless/demo/stephan/stacklessness/stacklessness.py spike(Download)

from threading import Event, currentThread, Lock, Thread
import time
import sys
import logging
from atexit import register
 
__all__ = 'run getcurrent getmain tasklet channel schedule'.split()

    mt = tasklet(None)
    mt._active = True
    mt._name = 'MainTask'
    maintask = currentThread()
    log.info(str(maintask))
    maintask.event = Event()
    mt.thread = maintask

def getcurrent():
    ct = currentThread()
    return ct.tasklet
 
def getmain():
    return maintasklet

    def schedule(self):
        log.info('%s Scheduler.schedule()' % getcurrent())
        log.info('\ttasklist:%s' % self)
        ct = currentThread()
        ctask = ct.tasklet
        log.info('\tcurrent tasklet is: %s' % ctask)
        nt = self.next()

src/s/t/stackless-HEAD/Stackless/demo/stephan/stacklessness/stacklessness.py stackless(Download)

from threading import Event, currentThread, Lock, Thread
import time
import sys
import logging
from atexit import register
 
__all__ = 'run getcurrent getmain tasklet channel schedule'.split()

    mt = tasklet(None)
    mt._active = True
    mt._name = 'MainTask'
    maintask = currentThread()
    log.info(str(maintask))
    maintask.event = Event()
    mt.thread = maintask

def getcurrent():
    ct = currentThread()
    return ct.tasklet
 
def getmain():
    return maintasklet

    def schedule(self):
        log.info('%s Scheduler.schedule()' % getcurrent())
        log.info('\ttasklist:%s' % self)
        ct = currentThread()
        ctask = ct.tasklet
        log.info('\tcurrent tasklet is: %s' % ctask)
        nt = self.next()

src/o/r/orcatorrent-HEAD/Core/APIImplementation/LaunchManyCore.py orcatorrent(Download)

import binascii
import shutil
from UserDict import DictMixin
from threading import RLock,Condition,Event,Thread,currentThread,enumerate
from traceback import print_exc,print_stack
from types import StringType

src/o/r/orcatorrent-HEAD/Core/Video/VideoOnDemand.py orcatorrent(Download)

# Written by Jan David Mol, Arno Bakker
# see LICENSE.txt for license information
 
import sys
from math import ceil
from threading import Lock,Condition,Event,RLock,currentThread
from traceback import print_exc,print_stack

src/o/r/orcatorrent-HEAD/Core/APIImplementation/DownloadImpl.py orcatorrent(Download)

import os
import copy
from traceback import print_exc,print_stack
from threading import RLock,Condition,Event,Thread,currentThread
 
from Tribler.Core.DownloadState import DownloadState
from Tribler.Core.DownloadConfig import DownloadStartupConfig

src/j/y/jython-HEAD/sandbox/tobias/jython/CPythonLib/_threading_local.py jython(Download)

                except KeyError:
                    pass # didn't have anything in this thread
 
from threading import currentThread, RLock

src/e/v/eventghost-HEAD/trunk/eg/Classes/SerialThread.py eventghost(Download)

# $LastChangedBy: bitmonster $
 
import eg
from threading import Thread, Lock, Condition, currentThread
from time import clock, sleep
from eg.WinApi.Dynamic import (
    # ctypes stuff

    def Close(self):
        """Closes  the serial port and stops all event processing."""
        self.keepAlive = False
        SetEvent(self.stopEvent)
        if currentThread() != self:
            self.join(1.0)
        if self.hFile:

    def Stop(self):
        """
        Stops the event processing of this class.
        """
        self.keepAlive = False
        SetEvent(self.stopEvent)
        if currentThread() != self:

src/z/a/zamboni-lib-HEAD/lib/python/logilab/common/proc.py zamboni-lib(Download)

import stat
from resource import getrlimit, setrlimit, RLIMIT_CPU, RLIMIT_AS
from signal import signal, SIGXCPU, SIGKILL, SIGUSR2, SIGUSR1
from threading import Timer, currentThread, Thread, Event
from time import time
 
from logilab.common.tree import Node

1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 Next