草庐IT

PopulateDB

全部标签

scala - 使用 Scala 的 Actor 时如何避免竞争条件

我正在编写一段代码,当缓冲区(列表)增长到一定大小时,它会填充一个mongoDB集合。importscala.actors.Actorimportcom.mongodb.casbah.Imports._importscala.collection.mutable.ListBufferclassPopulateDBextendsActor{valbuffer=newListBuffer[DBObject]valmongoConn=MongoConnection()valmongoCol=mongoConn("casbah_test")("logs")defadd(info:DBObjec