Python threading 模块，current_thread() 实例源码

我们从Python开源项目中，提取了以下50个代码示例，用于说明如何使用threading.current_thread()。

项目：kinect-2-libras 作者：inessadl | 项目源码 | 文件源码

def _decref(token, authkey, state, tls, idset, _Client):
        idset.discard(token.id)

        # check whether manager is still alive
        if state is None or state.value == State.STARTED:
            # tell manager this process no longer cares about referent
            try:
                util.debug('DECREF %r', token.id)
                conn = _Client(token.address, authkey=authkey)
                dispatch(conn, None, 'decref', (token.id,))
            except Exception, e:
                util.debug('... decref failed %s', e)

        else:
            util.debug('DECREF %r -- manager already shutdown', token.id)

        # check whether we can close this thread's connection because
        # the process owns no more references to objects for this manager
        if not idset and hasattr(tls, 'connection'):
            util.debug('thread %r has no more proxies so closing conn',
                       threading.current_thread().name)
            tls.connection.close()
            del tls.connection

项目：kinect-2-libras 作者：inessadl | 项目源码 | 文件源码

def __repr__(self):
        try:
            if self._semlock._is_mine():
                name = current_process().name
                if threading.current_thread().name != 'MainThread':
                    name += '|' + threading.current_thread().name
            elif self._semlock._get_value() == 1:
                name = 'None'
            elif self._semlock._count() > 0:
                name = 'SomeOtherThread'
            else:
                name = 'SomeOtherProcess'
        except Exception:
            name = 'unknown'
        return '<Lock(owner=%s)>' % name

#
# Recursive lock
#

项目：kinect-2-libras 作者：inessadl | 项目源码 | 文件源码

def __new__(cls, *args, **kw):
        self = object.__new__(cls)
        key = '_local__key', 'thread.local.' + str(id(self))
        object.__setattr__(self, '_local__key', key)
        object.__setattr__(self, '_local__args', (args, kw))
        object.__setattr__(self, '_local__lock', RLock())

        if (args or kw) and (cls.__init__ is object.__init__):
            raise TypeError("Initialization arguments are not supported")

        # We need to create the thread dict in anticipation of
        # __init__ being called, to make sure we don't call it
        # again ourselves.
        dict = object.__getattribute__(self, '__dict__')
        current_thread().__dict__[key] = dict

        return self

项目：kinect-2-libras 作者：inessadl | 项目源码 | 文件源码

def _patch(self):
    key = object.__getattribute__(self, '_local__key')
    d = current_thread().__dict__.get(key)
    if d is None:
        d = {}
        current_thread().__dict__[key] = d
        object.__setattr__(self, '__dict__', d)

        # we have a new instance dict, so call out __init__ if we have
        # one
        cls = type(self)
        if cls.__init__ is not object.__init__:
            args, kw = object.__getattribute__(self, '_local__args')
            cls.__init__(self, *args, **kw)
    else:
        object.__setattr__(self, '__dict__', d)

项目：wen_spiders 作者：HughWen | 项目源码 | 文件源码

def loop_parse_news_flashes(self, coll):
        while REDIS_CLIENT.scard(self.key) > 0:
            try:
                cur_id = REDIS_CLIENT.spop(self.generate_key())
                per_page = 20
                cur_url = self.news_flashes_tpl % (cur_id.decode("utf-8"), per_page)
                print(threading.current_thread().name + ' is crawling ' + cur_url)
                resp = self.p_get(cur_url).text
                resp_json = json.loads(resp)
                news_list = resp_json['data']['items']
                for news in news_list:
                    news.update({'_id': news['id']})
                    try:
                        if coll.find_one({'_id': news['id']}) is None:
                            self.save_doc(coll, news)
                    except Exception as e:
                        print(e)
            except Exception as e:
                print(e)

        print(threading.current_thread().name + ' is finish')

项目：zmirror 作者：aploium | 项目源码 | 文件源码

def cron_task_host():
    """??????, ?????????, ???????????"""
    while True:
        # ????????, ??????
        if not enable_cron_tasks:
            if threading.current_thread() != threading.main_thread():
                exit()
            else:
                return

        sleep(60)
        try:
            task_scheduler.run()
        except:  # coverage: exclude
            errprint('ErrorDuringExecutingCronTasks')
            traceback.print_exc()