redux-saga 什么时候使用 fork?

IT技术 reactjs redux redux-saga
2021-05-22 00:24:06

下面的两种方法有什么区别?

export function* watchLoginUser() {
  yield takeEvery(USER_LOGIN, loginUser)
}
export function* watchLogoutUser() {
  yield takeEvery(USER_LOGOUT, logoutUser)
}
export function* watchGetParties() {
  yield takeEvery(PARTIES_GET, getParties)
}
export default function* root() {
  yield [
    fork(watchLoginUser),
    fork(watchLogoutUser),
    fork(watchGetParties)
  ]
}
export default function* root() {
  yield [
    takeEvery(USER_LOGIN, loginUser),
    takeEvery(USER_LOGOUT, logoutUser),
    takeEvery(PARTIES_GET, getParties)
  ]
}

我什么时候需要使用叉子,什么时候不需要?

2个回答

通常,fork当 saga 需要启动非阻塞任务时很有用。这里的非阻塞是指:调用者启动任务并继续执行,无需等待任务完成。

这在很多情况下都有用,但主要有两种情况:

  • 按逻辑域对 sagas 进行分组
  • 保留对任务的引用以便能够取消/加入它

您的顶级传奇可以是第一个用例的示例。你可能会有这样的事情:

yield fork(authSaga);
yield fork(myDomainSpecificSaga);
// you could use here something like yield [];
// but it wouldn't make any difference here

哪里authSaga可能包括以下内容:

yield takeEvery(USER_REQUESTED_LOGIN, authenticateUser);
yield takeEvery(USER_REQUESTED_LOGOUT, logoutUser);

您可以看到此示例与您建议的相同,使用forksagatakeEvery调用产生调用。但实际上,您只需要出于代码组织的目的而这样做。takeEvery本身就是一个分叉任务,所以在大多数情况下,这将是无用的冗余。

第二个用例的一个例子是这样的:

yield take(USER_WAS_AUTHENTICATED);
const task = yield fork(monitorUserProfileUpdates);
yield take(USER_SIGNED_OUT);
yield cancel(task);

您可以在此示例中看到,monitorUserProfileUpdates在调用者 saga 恢复时将执行,并等待USER_SIGNED_OUT操作被分派。此外,它还可以保留对它的引用,以便在需要时取消它。

为了完整起见,还有另一种方法可以启动非阻塞调用:spawn. fork并且spawn不同之处在于错误和取消从子级到父级的冒泡方式。

通常fork对于具有多次 API 调用分派的某些情况变得更有用,原因是您可以通过从任务中实例化取消来拒绝这些提取,例如cancel(task1);

如果最终用户强行退出应用程序或其中一项任务失败而导致您的指令、策略和逻辑出现问题,并且取消或终止您的 saga 上的当前处理任务可能是合理的,则很有用;

两种方法可以取消任务

来自redux-saga 非阻塞效果取消文档的基础

import { take, put, call, fork, cancel } from 'redux-saga/effects'

// ...

function* loginFlow() {
  while (true) {
    const {user, password} = yield take('LOGIN_REQUEST')
    // Non-Blocking Effect which is the fork
    const task = yield fork(authorize, user, password)
    const action = yield take(['LOGOUT', 'LOGIN_ERROR'])
    if (action.type === 'LOGOUT'){
      //cancel the task
      yield cancel(task)
      yield call(Api.clearItem, 'token')
    }
  }
}

或者


import {call, put, fork, delay} from 'redux-saga/effects';
import someAction from 'action/someAction';

function* fetchAll() {
  yield fork(fetcher, 'users');
  yield fork(fetcher, 'posts');
  yield fork(fetcher, 'comments');
  yield delay(1500);
}

function* fetcher(endpoint) {
  const res = yield call(fetchAPI, endpoint);
  if (!res.status) {
    throw new Error(`Error: ${res.error}`);
  }
  yield put(someAction({payload: res.payload}));
}

function* worker() {
  try {
    yield call(fetchAll);
  } catch (err) {
    // handle fetchAll errors
  }
}

function* watcher() {
  yield takeEvery(BLOGS.PUSH, worker);
}

别客气 :)