약속을 사용하여 데이터 집합 생성

Question

현재 자바 스크립트에서 비동기 호출 쌍을 생성하려고하고 있지만 올바른 순서로 가져올 수 없습니다.

generateDataPoints: function (iterable, source, arg) { 
    let pairs = [] 
    let prevTime = 0 
    for (let index in iterable) { 
    let event = iterable[index] 
    getTime(event.valueOf()).then(function (time) { 
     query(source[arg], event.valueOf()).then(function(val) { 
     if (time !== prevTime) { 
      prevTime = time 
      pairs.push([time, val]) 
      console.log(pairs) // This works as expected but only happens after the program returns 
     } else { 
      Promise.resolve() 
     } 
     }) 
    }) 
    } 
    return Promise.resolve(pairs) 
} 

문제는 내가 돌아 오면 "pairs.push .."명령이 실행된다는 것입니다. 정확하게 무엇이 잘못되었는지, 어떻게이 프로세스를 동기화 할 수 있는지 파악할 수 없습니다. 어떤 도움을 주셔서 감사합니다.

Answer 1

동기식 코드 (예 : for 루프)를 비동기 코드와 혼합합니다.

이

function generateDataPoints(iterable, source, arg) { 
    let prevTime = 0 
    [...iterable].reduce((promiseChain, event) => { 
    let pairs; 
    return promiseChain 
     .then(p => { 
     pairs = p; 
     return Promise.all([ 
      getTime(event.valueOf()), 
      query(source[arg], event.valueOf()) 
     ]) 
     }) 
     .then(([time, val]) => { 
     if (time !== prevTime) { 
      prevTime = time 
      return pairs.concat([[time, val]]); 
     } else { 
      return pairs; 
     } 
     }); 
    }) 
    }, Promise.resolve([])); 
} 

이 결국 모든 쌍을 포함 순차적 약속 체인에 iterable을 감소 : 이런 식으로 뭔가를 시도하십시오. 사용자 환경이 가능하게되는 경우

, 당신은 또한 비동기 기능에 몇 가지 변화와 기능을 변환 할 수 있습니다 :

generateDataPoints: async function (iterable, source, arg) { 
    let pairs = [] 
    let prevTime = 0 
    for (let index in iterable) { 
    let event = iterable[index] 
    const [time, val] = await Promise.all([ 
     getTime(event.valueOf()), 
     query(source[arg], event.valueOf()) 
    ]); 
    if (time !== prevTime) { 
     prevTime = time 
     pairs.push([time, val]) 
    } 
    } 
    return pairs; 
} 

편집 :

을 자세히 살펴보면, 그것은하지 않습니다 당신이이 약속들을 순차화할 필요가있는 것처럼 보입니다. 다음과 같이 병렬로 실행할 수 있습니다 :

function generateDataPoints(iterable, source, arg) { 
    Promise.all(
    [...iterable].map(event => Promise.all([ 
     getTime(event.valueOf()), 
     query(source[arg], event.valueOf()) 
    ]) 
).then(pairs => { 
    let prevTime = 0 
    return pairs.filter(([time, val]) => { 
     if (time !== prevTime) { 
     prevTime = time; 
     return true; 
     } else { 
     return false; 
     } 
    }); 
    }); 
}