Рекурсивное асинхронное отсроченное перекрытие обещаний - PullRequest
Новая
       34

Рекурсивное асинхронное отсроченное перекрытие обещаний

0 голосов
/ 24 мая 2018

Вариант использования следующий: я хочу запрашивать URL каждые X миллисекунд, пока не получу положительный ответ.

Я пытаюсь добиться этого в JS (узел) и у меня проблема с несколькимитакие запросы.Если я запускаю только один из этих «цепных вызовов», все работает нормально.

Но если я пытаюсь запустить несколько из них параллельно, «последний выигрывает» (а первый никогда не разрешается).Я, кажется, использую ссылку на тот же объект или что-то, но я не могу понять это.

Обратите внимание, как переменные "masterCounter" и "id" перезаписываются, хотя они передаются как аргументы по значению.

Вот рабочий код (где «SECOND» побеждает «FIRST»):

(вы можете запустить с узлом, если вы установите пакет запроса https://www.npmjs.com/package/request)

var req = require('request');

const ASK_EVERY_MS = 500;
const AT_MOST_MS = 5000;

var childRecursive = (t, resolve, reject, t0, id, masterCounter) => {    
    var duration = process.hrtime(t0);    
    duration = (duration[0] * Math.pow(10, 9) + duration[1]) / Math.pow(10, 6)
    if (duration + t > AT_MOST_MS) {
        reject('timeout');
    } else {
        var options = {
            url: 'http://www.google.com',
            json: false,
            headers: {
                timeout: 1000
            }
        };
        callback = function (error, response, body) {
            if (!error) {
                console.log('body', body.substring(0, 100));
                if (masterCounter % 5 == 0) {
                    return resolve("success!!!");
                } else {
                    return childRecursive(ASK_EVERY_MS, resolve, reject, t0, id, masterCounter + 1, req);
                }
            } else {
                console.log('problem with submission GET request: ' + error);
                return reject(error);
            }
        }
        console.log(id + ' masterCounter is ' + masterCounter);
        setTimeout(() => {
            console.log(id + ' requesting...');
            req.get(options, callback);
        }, t);
    }
};

var t0 = process.hrtime();
var first = new Promise((resolve, reject) => childRecursive(0, resolve, reject, t0, 'FIRST', 101));
first.then(() => {
    console.log('FIRST done');
});
var scnd = new Promise((resolve, reject) => childRecursive(0, resolve, reject, t0, 'SECOND', 201));
scnd.then(() => {
   console.log('SECOND done');
});

и вывод: 

FIRST masterCounter is 101
SECOND masterCounter is 201
FIRST requesting...
SECOND requesting...
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content
SECOND masterCounter is 202
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content
SECOND masterCounter is 202
SECOND requesting...
SECOND requesting...
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content
SECOND masterCounter is 203
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content
SECOND masterCounter is 203
SECOND requesting...
SECOND requesting...
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content
SECOND masterCounter is 204
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content
SECOND masterCounter is 204
SECOND requesting...
SECOND requesting...
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content
SECOND masterCounter is 205
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content
SECOND masterCounter is 205
SECOND requesting...
SECOND requesting...
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content
SECOND done
body <!doctype html><html itemscope="" itemtype="http://schema.org/WebPage" lang="hr"><head><meta content

1 Ответ

0 голосов
/ 24 мая 2018

Ваша проблема в неявно глобальной переменной callback.Это должно быть 

var callback = function (error, response, body) { /*
^^^ */

или 

function callback(error, response, body) {

Всегда use strict режим , чтобы избежать таких ошибок!

...