工作代码:在Chrome,Firefox中
let sleep = function (ms) {
return new Promise(resolve => setTimeout(resolve, ms))
};
在我的函数中的某个地方,我使用异步,等待使延迟同步
function updateHandler(newTags, tagName, contentIds) {
let deferred = Q.defer(),
counter = 0,
failedIDS = [],
data = {};
data["contentIds"] = contentIds;
data["failedIDS"] = failedIDS;
if (contentIds.length === 0) {
return Promise.resolve(data);
}
//aync and await is here
_.forEach(contentIds, async function (contentId) {
//wait for some time and continue
await sleep(150);
let tags = [], activity;
//API hits..
osapi.jive.core.get({
v: "v3",
href: "/contents/" + contentId + ""
}).execute(function (content) {
tags = content.tags;
activity = content["updated"];
content["tags"] = _.union(tags, newTags);
osapi.jive.core.put({
v: "v3",
href: "/contents/" + contentId + "",
body: content,
"minor": "true",
"updated": activity
}).execute(function (response) {
counter++;
if (response.error) {
failedIDS.push(contentId);
}
if (counter === contentIds.length) {
deferred.resolve(data);
}
}, function (error) {
counter++;
failedIDS.push(contentId);
if (counter === contentIds.length) {
deferred.resolve(data);
}
}
);
})
});
return deferred.promise;
};
因此,这个api命中必须有0.15秒才能工作并更新所有项目。
由于async和await在IE中不起作用,我想编写一个等待0.15秒的基本wait(ms)
函数。
注意:因此,如果没有sleep()
函数,上面的循环在第一次迭代时工作正常,第二次迭代失败并终止代码执行。因此,每次迭代必须延迟0.15秒,这是产品限制。
setTimeout()
是异步的..所以我没有使用它。
下面的代码对我有用..但它不是我想要的,因为浏览器耗尽了内存和更多的CPU利用率,价格昂贵..
function wait(ms) {
console.log("started............");
var start = Date.now(),
now = start;
while (now - start < ms) {
now = Date.now();
}
console.log("finished............");
}
问题:我希望每次迭代至少延迟0.15秒,我该如何实现它。
++我尝试了以下方式,图片在这里。在没有error
函数的情况下,成功更新了100个可迭代项目中的16到19个内容,然后抛出相同的sleep()
。
假设我需要每150ms运行一次这个请求函数:
const request = () => new Promise(res => setTimeout(() => { console.log('done'); res() }, 1000))
//
然后我可以递归地使用setTimeout
在每个请求之间添加延迟:
let counter = 0;
// this handler will be passed into a setTimeout
// to kick off the whole thing
const handler = () => {
console.log(counter);
// request api thing
request().then(() => {
counter++;
if (counter === 100) return;
setTimeout(handler, 150) // remove this
})
}
// kick off
setTimeout(handler, 150)
它确保在等待运行下一个请求之前完成每个请求。