Tag: race condition

避免与nodejs的竞争条件

我正在使用nodeJS 6.3.0和aws DynamoDB编写一个应用程序。 dynamodb拥有从10个不同的function(10种不同的统计量度)中被添加到dynamodb的统计信息。 间隔时间设置为10秒,这意味着每10秒钟,10次调用我的function正在添加所有的相关信息。 putItem函数: function putItem(tableName,itemData,callback) { var params = { TableName: tableName, Item: itemData }; docClient.put(params, function(err, data) { if (err) { logger.error(params,"putItem failed in dynamodb"); callback(err,null); } else { callback(null,data); } }); 现在…我创build了一个队列。 var queue = require('./dynamoDbQueue').queue; 它实现了一个固定大小的简单队列,我使用http://www.bennadel.com/blog/2308-creating-a-fixed-length-queue-in-javascript-using-arrays.htm 。 这个想法是,如果有networking问题..让我们说一分钟。 我希望所有的事件都被推送到队列中,当问题解决后,发送队列信息给dynamodb并释放队列。 所以我将我的原始function修改为以下代码: function putItem(tableName,itemData,callback) { var params = { TableName: tableName, […]