全局dict,不是所有线程都向其添加密钥



我对Python中的全局变量感到困惑。有时一个全局变量在我的程序的所有实例之间共享,有时一个实例会创建自己版本的全局变量。

我需要的是有一个处理程序来处理放入全局字典中的项。只有一个函数可以向全局字典中添加项,但该函数会同时运行多次。

视图中:

global_dict = {}
def handler():
    global global_dict 
    print "Starting handler"
    while True:
        local_dict = dict(global_dict) 
        for key, v in local_dict.iteritems():
            handle_the_item(v)
            del global_dict[key]
            print "Handled: ", key
        time.sleep(0.05)
def some_function(function_number)
    global global_dict
    print "Starting function", function_number
    for x in y:
        key = random.randint(0, 5000000)
        print function_number, "giving to handler:", key
        global_dict[key] = some_item

我开始:

(我使用Django,所以每个函数都是通过调用带有一些参数的url来启动的(

handler()
some_function(1)
some_function(2)
some_function(3)

它打印:

Starting handler
Starting function 1
Starting function 2
Starting function 3
1 giving to handler 111111
2 giving to handler 222222
3 giving to handler 333333
1 giving to handler 444444
2 giving to handler 555555
3 giving to handler 666666
Handled: 111111
Handled: 222222
Handled: 444444
Handled: 555555

处理程序从不处理函数3添加的项。据我所知,这是因为处理程序和函数3都有自己的全局变量global_dict实例。我还通过在some_function((中打印出global_dict的长度来验证这一点。函数3中的global_dict随着项目的增加而不断增长。

请注意,哪些函数共享global_dict实例,哪些函数拥有自己的实例,这是随机的。如果我停止一切并再次运行它,那么可能所有实例都共享global_dict。或者没有。或者3和1以及处理程序。

当您在web服务器后面运行Django等应用程序时,web服务器通常会将应用程序的多个实例作为单独的长进程运行。如果多个请求汇集在一起,它们将分布在应用程序进程中。

这意味着您不能依赖于跨请求共享的全局变量。您可能很幸运,请求进入同一个进程,也可能不幸运,不同的请求进入应用程序的不同实例。

如果您需要在web请求之间共享状态,那么您应该使用其他机制,如数据库或memcached。

相关内容

  • 没有找到相关文章

最新更新