threading.current_thread

All Samples(160) | Call(93) | Derive(0) | Import(67)

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/i/r/ironruby-HEAD/External.LCA_RESTRICTED/Languages/IronPython/27/Lib/_threading_local.py ironruby(Download)

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

src/i/r/ironruby-HEAD/External.LCA_RESTRICTED/Languages/CPython/27/Lib/_threading_local.py ironruby(Download)

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

src/g/e/genropy-HEAD/gnrpy/gnr/sql/ThreadingLocal.py genropy(Download)

 
 
try:
    from threading import current_thread
except ImportError: # Python >2.5
    from threading import currentThread as current_thread
from threading import RLock, enumerate

src/w/u/wu-ros-pkg-HEAD/stacks/wu_utils/trunk/pymp/src/pymp/dispatcher.py wu-ros-pkg(Download)

import functools
import time
import traceback
from multiprocessing.util import Finalize
from threading import Event, RLock, Thread, current_thread
from pymp import logger, trace_function
from pymp.messages import DispatcherState, Request, Response, ProxyHandle, generate_id

src/w/u/wu-ros-pkg-HEAD/externals/wu-ros-pkg/wu_utils/pymp/src/pymp/dispatcher.py wu-ros-pkg(Download)

import functools
import time
import traceback
from multiprocessing.util import Finalize
from threading import Event, RLock, Thread, current_thread
from pymp import logger, trace_function
from pymp.messages import DispatcherState, Request, Response, ProxyHandle, generate_id

src/p/y/pypy3-HEAD/lib-python/3.1.2/_threading_local.py pypy3(Download)

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

src/p/y/pythomnic3k-HEAD/sandbox/dsuch/pmnc-cmdline/lib/interlocked_queue.py pythomnic3k(Download)

 
    ###################################
 
    from threading import Thread, current_thread
    from time import sleep
    from random import random

        def pop(q, t = None):
            go.wait()
            current_thread().result = q.pop(t)
 
        ###############################
 
        th1 = Thread(target = pop, args = (que, ))

src/p/y/pythomnic3k-HEAD/trunk/lib/pmnc/threads.py pythomnic3k(Download)

 
################################################################################
 
import threading; from threading import Event, Thread, current_thread
try:
    import pythoncom; from pythoncom import CoInitializeEx, CoUninitialize, COINIT_MULTITHREADED
except:

    def run(self):
        current_thread()._request = InfiniteRequest() # has an infinite request attached
        PmncThread.run(self)
 
    def stopped(self, timeout = None):
        if timeout is not None:
            self.__stop.wait(timeout) # this may spend waiting slightly less, but it's ok
        return self.__stop.is_set()
 
    def stop(self):
        self.__stop.set()
        if current_thread() is not self:

src/p/y/python2.6-cmake-HEAD/Lib/_threading_local.py python2.6-cmake(Download)

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

src/p/y/pyvm-HEAD/projects/python_in_a_can/trunk/win32/python-2.7/Lib/_threading_local.py pyvm(Download)

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

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