
复制db.queue.insert( { _id : 123,设计 message : { }, locked : false, tlocked : ISODate(), try : 0 }); var timerange = date.Now() - TIMECONSTANT; var doc = db.queue.findAndModify( { $or : [ { locked : false }, { locked : true, tlocked : { $lt : timerange } } ], { $set : { locked : true, tlocked : date.Now(), $inc : { try : 1 } } } ); //do some processing db.queue.update( { _id : 123, try : doc.try }, { } ); 1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.