在Python中(使用Django),当全局字典数据结构正在更新时,我如何阻止对其的访问?

9 浏览
0 Comments

在Python中(使用Django),当全局字典数据结构正在更新时,我如何阻止对其的访问?

在Django中,当更新一个全局字典数据结构时,我想通过不同的请求来锁定对它的访问。我计划使用一个包装函数来更新、访问和同步它。我有Java背景!有什么指导吗?

0
0 Comments

在Python(Django)中,如何在更新全局字典数据结构时停止访问的问题是因为需要在多线程环境下保证数据安全性。解决这个问题的方法是使用一个可锁定的字典类,根据调用者的执行帧来自动锁定和解锁字典,以防止并发访问和更新导致的数据不一致。

以下是解决这个问题的代码示例:

from inspect import stack
class DictLocked(Exception):
    pass
class LockableDict(dict):
    def __init__(self, *args, **kw):
        dict.__init__(self, *args, **kw)
        self.locked = False
        self.locker = None
    
    def start_update(self):
        print stack()
        self.locked = True
        # 保存锁定的代码帧
        self.locker = stack()[1][0]
    
    def finish_update(self):
        self.locked = False
    
    def __getitem__(self, item):
        print stack()
        if self.locked:
            if stack()[1][0] != self.locker:
                raise DictLocked("Dictionary locked")
        return dict.__getitem__(self, item)
    
    def __setitem__(self, item, value):
        if self.locked:
            if stack()[1][0] != self.locker:
                raise DictLocked("Dictionary locked")
        return dict.__setitem__(self, item, value)

通过使用这个LockableDict类,我们可以在需要更新全局字典数据结构时调用start_update()方法,该方法会锁定字典,阻止其他线程对其进行访问和更新。在更新完成后,我们可以调用finish_update()方法解锁字典。

在访问字典的时候,我们可以通过重写__getitem__()和__setitem__()方法来检查字典是否被锁定。如果字典被锁定且当前执行帧与锁定帧不一致,则抛出DictLocked异常,阻止对字典的访问或更新。

这样,我们就可以确保在更新全局字典数据结构时,其他线程无法访问和更新,从而保证数据的一致性和安全性。

0
0 Comments

问题出现的原因是在多线程环境下,当全局字典数据结构正在被更新时,其他线程仍然可以访问该字典,导致数据不一致或出现错误。

为了解决这个问题,可以使用锁机制来控制对全局字典的访问。在Python中,可以使用threading模块中的Lock类来实现锁。

首先,定义一个LockableDict类,继承自dict类,并添加一个名为lock的Lock对象作为类的属性。在类的初始化方法__init__中,通过调用dict类的初始化方法来初始化字典,并创建一个Lock对象。接下来,添加locked方法来判断锁是否被获取,lock方法来获取锁,unlock方法来释放锁。

然后,创建一个LockableDict的实例my_dict,并使用lock方法获取锁,进行对字典的修改操作,最后使用unlock方法释放锁。

代码如下:

class LockableDict(dict):
    def __init__(self, *args, **kwargs):
        from threading import Lock
        self.lock = Lock()
        dict.__init__(self, *args, **kwargs)
        
    def locked(self):
        return self.lock.locked()
        
    def lock(self):
        self.lock.acquire()
        
    def unlock(self):
        self.lock.release()
# and then
my_dict = LockableDict({1:2, 3:4})
my_dict.lock()
# do modifications
my_dict.unlock()

在上述代码中,通过创建一个LockableDict的实例my_dict,并使用lock方法获取锁,这样其他线程就无法访问该字典。在进行修改操作后,使用unlock方法释放锁,其他线程可以再次访问该字典。

注意,为了避免锁的名称与函数和变量名相同,可以将锁的属性名称改为__lock,使其成为私有属性。

通过上述方法,可以在多线程环境下有效地控制对全局字典数据结构的访问,避免数据不一致或错误的发生。

0