Как заменить цикл while?

Question

[yopive3562]

Доброго времени суток!
В программе выполняется код после получения данных. Параллельно приходит множество данных.
Данные необходимо обрабатывать. Код написан с использованием async\await. В определенный момент данные нужно обработать выполнив тяжелую функцию.
Проблема в том, что данные могут придти похожие и тогда их обработка не нужна, нужно лишь дождаться уже идущей обработки таких данных и взять результат. В этом моменте и использую while с засыпанием на 100мс с последующей проверкой окончания выполнения.
Продолжать выполнение нельзя без окончания обработки.
Как в таких случаях поступают? Думаю, что это так себе вариант реализации.

upd1:
Допустим, что входные данные это числовое значение. Приходят 4 входных значения.
1)1
2)2
3)3
4)1
и вот для 4-ых входных данных не нужно выполнять проверку, потому что она еще выполняется для 1-ых. из-за этого приходится стопорить код циклом вида

while(!isChecked) {
   await sleep(100) // промис возвращающийся через 100мс
}

Comments

[Дмитрий Беляев]

а по каким признакам Вы поймете, что данные "похожие"?
Вообще на промисах такое делается, они как раз сделаны, чтоб асинхронно ждать чего либо. И async/await - это сахар как раз над промисами.

[yopive3562]

Дмитрий Беляев, допустим, по значению. приходят 4 входных значения.
1)1
2)2
3)3
4)1
и вот для 4-ых входных данных не нужно выполнять проверку, потому что она еще выполняется для 1-ых. из-за этого приходится стопорить код циклом вида
while(!isChecked) {
await sleep(100) // промис возвращающийся через 100мс
}

[Дмитрий Беляев]

yopive3562, я не просто так спросил про похожесть, идея такая:
при запуске задачи добавляйте в общий Map промис ожидающий текущую задачу, в качестве ключа используйте общий признак (главное чтоб он сравнивался по значению).
Если промис для задачи уже есть в Map, то просто await'им его вместо выполнения задачи

[yopive3562]

Дмитрий Беляев, звучит, как то, что и искал я!
что-то вроде такого?
Вроде бы работает, как и хотел. Отправьте ответ, чтобы я отметил его решением. Было бы круто, если бы показали какой-нить изящный код)

let checkPull = {}
let testData = ["test1", "test2", "test3", "test1"]
for(let item of testData) run(item)

async function run(item) {
    
        console.log(`input data ${item}`);
        
        if(!checkPull[item]) {
            console.log(`start check ${item}`);
            checkPull[item] = timeout(1000 * 5)
            
        }
        else {
            console.log(`skip check ${item}`);
            
        }
        await checkPull[item]
        console.log(`check ${item} done`);
    
}

Answer 1

[Сергей delphinpro]

В простейшем случае используйте коллбэк в обработке данных

function processData(callback){
  // тяжелая обработка...
  callback();
}

processData(function(){
  // Данные обработаны
});

Или прикрутите промисы, и сможете использовать async/await

Comments

[yopive3562]

Сергей delphinpro все это понятно, про промисы и колбеки. вопрос немного про другое. посмотрите вопрос, я немного ниже добавил уточнение.
входные данные 1, 4 имеют одинаковое значение. но только в одном случае их нужно обрабатывать - иначе ждать выполнения проверки. Async/await и так используется, но не приходит в голову, как красиво завернуть все, чтобы обойтись без цикла while. Если такое вообще возможно