Подсчитайте, сколько раз я посещаю нить

Question

У меня есть следующий код, который подсчитывает, сколько раз я посещаю нить. Код работает нормально, но я хочу узнать, можно ли реализовать это без какой-либо глобальной переменной.

import threading 
import lib.logging 
import time 

count = 0 

class Monitor(threading.Thread): 
    def __init__(self, count): 
     threading.Thread.__init__(self) 

    def run(self): 
     global count 
     count+=1 
     lib.logging.debug ("Count is: " + str(count)) 

def main():   
    for i in xrange(3): 
     t1 = Monitor(count) 
     t2 = Monitor(count) 
     t1.start() 
     t2.start() 
     t1.join() 
     t2.join() 
     time.sleep(3) 

    print "done" 

Большое спасибо

Answer 1

Это можно считать вызов функции без глобальной переменной с помощью itertools.count и Питона функция аргументы по умолчанию поведение:

import threading 
import lib.logging 
import time 
from itertools import count 


class Monitor(threading.Thread): 
    def __init__(self): 
     threading.Thread.__init__(self) 

    def run(self, count=count()): 
     # next(count) starts from 0, so to log first '1', + 1 is used 
     lib.logging.debug ("Count is: " + str(next(count) + 1)) 

def main():   
    for i in xrange(3): 
     t1 = Monitor() 
     t2 = Monitor() 
     t1.start() 
     t2.start() 
     t1.join() 
     t2.join() 
     time.sleep(3) 

    print "done" 

Вот пост про аргументы питона функции по умолчанию: http://www.lexev.org/en/2013/python-mutable-default-arguments/

Answer 2

Одним из возможных решений является использование «полу-сохранялось» в памяти счетчика.

Например

#!/usr/bin/env python 
# -*- coding: utf-8 -*- 


import threading 
import time 
import redis 


class RedisCounter(object): 

    def __init__(self, db, host, port, key, reset=False): 
     pool = redis.ConnectionPool(host=host, port=port, db=db) 
     self.conn = redis.StrictRedis(connection_pool=pool) 
     self.key = key 

     if reset: 
      self.initialize() 

    def initialize(self): 
     self.conn.set(self.key, 0) 

    def incr(self): 
     self.conn.incr(self.key) 

    def get(self): 
     return int(self.conn.get(self.key)) 


class Monitor(threading.Thread): 

    def __init__(self, counter): 
     threading.Thread.__init__(self) 
     self.counter = counter 

    def run(self): 
     self.counter.incr() 
     print("Count is: " + str(self.counter.get())) 


def main(): 
    counter = RedisCounter(0, 'localhost', 6379, 'thread_counter', True) 

    for i in xrange(3): 
     t1 = Monitor(counter) 
     t2 = Monitor(counter) 
     t1.start() 
     t2.start() 
     t1.join() 
     t2.join() 
     time.sleep(3) 

    print "done" 

if __name__ == '__main__': 
    main() 

Это может быть излишним для вас, но направление решения такой проблемы, тем не менее :)