Как сработает цикл событий в данной ситуации?

Question

[everpi]

Здравствуйте. Что если код дойдет до await.fetch() и в этот момент сработает интервал и удалит массив, в который мы собираемся пушить данные после асинхронной операции, мы получим 'Cannot read property 'push' of undefined'?)

const session = {
    unanswered: [],
    isRedirect: true,
    date: 1545762010253
};

client.on('message', async (msg) => {
    if (session.isRedirect) {
        await fetch(...);
        session.unanswered.push(msg.id);
    } else {
        session.isRedirect = true;
        session.unanswered = [];
        session.date = Date.now() + 60 * 1000;
    }
});

setInterval(() => {
    if (Date.now() > session.date) {
        session.isRedirect = false;
        delete session.unanswered;
    }
}, 100);

Исправит ли эту проблему заворачивание коллбека в setImmediate() и будет ли это хорошим решением данной проблемы?

На самом деле пример плохой и не отражает моей проблемы. Мне нужно чтобы когда одна функцию манипулирует над объектом ей не мешали другие. setImmediate бы подошел (он как я понял ставит исполнение коллбека перед интервалом), но когда в on('message') вызываются асинхронные функции поток выполнения передается интервалу и все в кашу :)

Comments

[Алексей Ярков]

Рекомендую к просмотру: Иван Тулуп: асинхронщина в JS под капотом

[everpi]

Алексей Ярков, спасибо. Я в итоге вот такую функцию написал

const doAfterUnlock = async (session, func, ...args) => {
    while (session.isBlock) {
        // eslint-disable-next-line no-await-in-loop
        await delay(1); // free event loop
    }

    try {
        session.isBlock = true;
        await func(...args);
    } catch (e) {
        console.error(e);
    } finally {
        session.isBlock = false;
    }
};

Answer 1

[everpi]

const delay = ms => new Promise(res => setTimeout(res, ms));

const doAfterUnlock = async (session, func, ...args) => {
    while (session.isBlock) {
        // eslint-disable-next-line no-await-in-loop
        await delay(1); // free event loop
    }

    try {
        session.isBlock = true;
        await func(...args);
    } catch (e) {
        console.error(e);
    } finally {
        session.isBlock = false;
    }
};

Answer 2

[Алексей]

Собственно говоря может не удалять массив вовсе, а как и в запросе, устанавливать пустым.

if (Date.now() > session.date) {
    session.isRedirect = false;
    session.unanswered = [];
}

...нет, не пойдет?

Comments

[everpi]

В этом примере решит, но это не то что я хотел услышать в ответе :) мне нужно чтобы код из on('message') выполнялся только если над объектом не манипулируют другие сервисы (в данном случае интервал), и наоборот. Код в таймауте тоже может быть асинхронным. Единственное решение которое я для себя нашел это еще один флаг, isBlock, но мне не нравится такое решение с

while(isBlock) {}

[Алексей]

everpi, а вы куда собираетесь поставить while(isBlock) {}? Если перед условием
if (session.isRedirect), то все равно, пока вы дождетесь fetch, все может изменится и session может оказаться просроченной, а если после fetcha, то запрос вы все равно уже выполнили, и ваше требование

мне нужно чтобы код из on('message') выполнялся только если над объектом не манипулируют другие сервисы

уже не соблюдается. И начинает все упираться в то, какую цель вы преследуете (со стороны мне сложно об этом судить), если главное - это не напороться на несуществующий массив, то вынесите fetch из условия:

await fetch(...);
if (session.isRedirect) {
    session.unanswered.push(msg.id);
} else {
    ...
}

либо сделайте проверку на существование session.unanswered
А setImmediate здесь, ни как не решит проблемы. И самое главное setImmediate, читай top highlight.

Answer 3

[Марат Гарифуллин]

Возможно что-то такое

const session = {
    unanswered: [],
    isRedirect: true,
    date: 1545762010253
};
const intervalID = null;
const checkSession = () => {
    if (Date.now() > session.date) {
        session.isRedirect = false;
        delete session.unanswered;
    }
};

client.on('message', async (msg) => {
    if (session.isRedirect) {
        сlearInterval(intervalID);
        await fetch(...);
        session.unanswered.push(msg.id);
        intervalID = setInterval(checkSession, 100);
    } else {
        session.isRedirect = true;
        session.unanswered = [];
        session.date = Date.now() + 60 * 1000;
    }
});

intervalID = setInterval(checkSession, 100);

Comments

[Алексей]

Сам по себе код жизнеспособный, но как мне кажется, под задумку автора не подходит данное решение. В твоем коде происходит отсекание проверки сессии на время выполнения fetch и да не произойдет изменений в объекте и как следствие возможного обращения к несуществующему свойству. Но фактически, сессия может оказаться просроченной пока выполняется fetch, просто ты это не проверяешь, и получается что ты выполняешь запрос и пушишь в уже сгоревшую сессию.