扭曲和python列表并发访问

Question

我有一个与扭曲的Python并发访问列表的问题。 我有一个扭曲的类，它将数据添加到列表中，并且每4秒调用一次该方法。这个方法是列表的元素并且执行一些操作。 我担心从ossPeriodic和从dataReceived访问相同的列表都可能导致一致性问题。 这里是代码：

ossStorage=[] 

def ossPeriodic(): 
for i in ossStorage: 
      ossStorage.remove(i) 
    db.insertDataToDb(i) 
reactor.callLater(4, ossPeriodic) 

class OSS(Protocol): 
    def dataReceived(self, data): 
     account = pickle.loads(data)   
     ossStorage.append(account) 



def main(): 
    ossFactory = Factory() 
    ossFactory.protocol = OSS 
    reactor.listenTCP(50000, ossFactory)  
    reactor.callLater(4, ossPeriodic) 
    reactor.run() 

我应该使用锁或类似的东西吗？ 谢谢！

Answer 1

你使用线程吗？如果没有，那么你没有并发访问列表。

通常，使用Twisted的应用程序不使用线程。 Twisted的异步性质在单个线程中按顺序处理每个事件。异步性质提供类似并发的行为，例如并行处理多个网络连接，但每个回调函数在调用下一个函数之前运行完成。