// 最初的同步實現(xiàn)版本
function renderItems(items) {
 for (item of items) {
 renderItem(item);
 }
}
// 函數(shù)將由我們的執(zhí)行器遍歷執(zhí)行
// 實際上，我們可以用相同的同步方式來執(zhí)行它！
function* renderItems(items) {
 // 我使用 for..of 遍歷方法來避免新函數(shù)的產(chǎn)生
 for (item of items) {
 yield renderItem(item);
 }
}

function runWithBatch(chunk, fn, ...args) {
 const gen = fn(...args);
 let num = 0;
 return new Promise((resolve, promiseReject) => {
 callNextStep();
 function callNextStep(res) {
  let result;
  try {
  result = gen.next(res);
  } catch (e) {
  return reject(e);
  }
  next(result);
 }
 function next({ done, value }) {
  if (done) {
  return resolve(value);
  }
  // every chunk we sleep for a tick
  if (num++ % chunk === 0) {
  return sleep(4).then(proceed);
  } else {
  return proceed();
  }
  function proceed() {
  return callNextStep(value);
  }
 }
 });
}
// 第一個參數(shù) —— 每批處理多少個項目
const items = [...];
batchRunner(2, function*() {
 for (item of items) {
 yield renderItem(item);
 }
});

function runWithCancel(fn, ...args) {
 const gen = fn(...args);
 let cancelled, cancel;
 const promise = new Promise((resolve, promiseReject) => {
 // define cancel function to return it from our fn
 // 定義 cancel 方法，并返回它
 cancel = () => {
  cancelled = true;
  reject({ reason: 'cancelled' });
 };
 onFulfilled();
 function onFulfilled(res) {
  if (!cancelled) {
  let result;
  try {
   result = gen.next(res);
  } catch (e) {
   return reject(e);
  }
  next(result);
  return null;
  }
 }
 function onRejected(err) {
  var result;
  try {
  result = gen.throw(err);
  } catch (e) {
  return reject(e);
  }
  next(result);
 }
 function next({ done, value }) {
  if (done) {
  return resolve(value);
  }
  // 假設(shè)我們總是接收 Promise，所以不需要檢查類型
  return value.then(onFulfilled, onRejected);
 }
 });
 return { promise, cancel };
}

// 實現(xiàn)渲染的方法還是一樣的
function* renderItems() {
 for (item of items) {
 yield renderItem(item);
 }
}
function runWithPause(genFn, ...args) {
 let pausePromiseResolve = null;
 let pausePromise;
 const gen = genFn(...args);
 const promise = new Promise((resolve, reject) => {
 onFulfilledWithPromise();
 function onFulfilledWithPromise(res) {
  if (pausePromise) {
  pausePromise.then(() => onFulfilled(res));
  } else {
  onFulfilled(res);
  }
 }
 function onFulfilled(res) {
  let result;
  try {
  result = gen.next(res);
  } catch (e) {
  return reject(e);
  }
  next(result);
  return null;
 }
 function onRejected(err) {
  var result;
  try {
  result = gen.throw(err);
  } catch (e) {
  return reject(e);
  }
  next(result);
 }
 function next({ done, value }) {
  if (done) {
  return resolve(value);
  }
  // 假設(shè)我們總是接收 Promise，所以不需要檢查類型
  return value.then(onFulfilledWithPromise, onRejected);
 }
 });
 return {
 pause: () => {
  pausePromise = new Promise(resolve => {
  pausePromiseResolve = resolve;
  });
 },
 resume: () => {
  pausePromiseResolve();
  pausePromise = null;
 },
 promise
 };
}

function* renderItems() {
 for (item of items) {
 // 我們需要將所有東西傳遞出去：
 // 方法, 內(nèi)容, 參數(shù)
 yield [renderItem, null, item];
 }
}

function runWithIgnore(fn, ...args) {
 const gen = fn(...args);
 return new Promise((resolve, promiseReject) => {
 onFulfilled();
 function onFulfilled(res) {
  proceed({ data: res });
 }
 // 這些是 yield 返回的錯誤
 // 我們想忽略它們
 // 所以我們像往常一樣做，但不去傳遞出錯誤
 function onRejected(error) {
  proceed({ error });
 }
 function proceed(data) {
  let result;
  try {
  result = gen.next(data);
  } catch (e) {
  // 這些錯誤是同步錯誤（比如 TypeError 等）
  return reject(e);
  }
  // 為了區(qū)分錯誤和正常的結(jié)果
  // 我們用它來執(zhí)行
  next(result);
 }
 function next({ done, value }) {
  if (done) {
  return resolve(value);
  }
  // 假設(shè)我們總是接收 Promise，所以不需要檢查類型
  return value.then(onFulfilled, onRejected);
 }
 });
}