Vue中watch清除过期副作用的案例详解

// 下拉选择器绑定的数据
const queryParams = Reactive({
    keyWord: ''
})

// 下拉列表渲染的数据
const listData = []

// 第几次搜索
let askNum = 0

// 每次搜索用的事件
const times = [5000, 100] // 第一次一共用了5s   第二次用了0.1s

// 监视书的信息
watch(queryParams, async (newV) => {
  // 3.查询参数第一次发生变化，响应很慢需要5s
  // 6.查询参数第二次发生变化，响应非常快

  asyncTaskIsExpired(times[askNum++], askNum)
    .then(() => {
      console.log(`第${askNum}个任务执行完毕`)
      // 渲染列表数据
      renderSelectData()
    })
})


function asyncTaskIsExpired(time, count) {
  return new Promise((resolve) => {
    console.log(`第${count}个任务开始了`)
    setTimeout(() => {
      resolve()
    }, time)
  })
}

const changeParams = function (str) {
  queryParams.keyword = str
}

function renderSelectData () {
    // do something
    console.log('渲染数据')
}

// 第一次搜索
changeBook('xxx')
// 第一次搜索过了两秒还没有返回数据
setTimeout(() => {
  // 就开始了第二次搜索
  changeBook('yyy')
}, 2000)

// watch的第三个参数，可以注册一个过期回调，当这个副作用函数的执行过期时将标识修改为true
// 换句话说，就是在watch内部每次检测到变化时，在副作用函数执行之前，会先执行通过onValidate注册的回调
watch(book, async (newV, oldV, onInvalidate) => {
  // 添加一个变量，标识上一次的请求是否过期
  let expired = false // 默认是不过期的
  onInvalidate(() => {
    // 过期时，将expired设置为true
    console.log('副作用函数已过期')
    expired = true
  })
  // asyncTask(times[askNum++], askNum)
  asyncTaskIsExpired(times[askNum++], askNum)
    .then(() => {
      if (!expired) {
        console.log(`第${askNum}个任务执行完毕`)
        renderSelectData()
      }
    })
})

// 递归读取对象中的数据（让对象中的所有key都有对应副作用函数）
// 从而保证修改响应式对象的任意属性watch都能监听得到然后执行副作用函数
function traverse (value, seen = new Set()) {
    // 如果要读取的数据是原始值或者已经读取过了，那么什么都不做
    if (typeof value !== 'object' || value !== null || seen.has(value)) return
    // 将数据添加到seen中，待变遍历地读取过了，避免循环引用引起的死循环
    seen.add(value)
    // 假设value是一个对象，使用for-in读取对象的每一个值，并递归调用traverse进行处理
    for (const key in value) {
        traverse(value[k], seen)
    }
}

function watch (source, cb, options) {
    let getter
    if (typeof source === 'function') {
        getter = source
    } else {
        // 如果watch监听的是一个对象，读取对象的所有属性
        getter = () => traverse(source)
    }

    let oldValue, newValue
    // cleanup用来存储用户注册的过期回调
    let cleanup
    function onInvalidate(fn) {
        // 过期回调保存到cleanup中
        cleanup = fn
    }

    const job = () => {
        newValue = effectFn()
        // 调用回调函数cb之前，如果有国企的回调就先调用过期回调
        if (cleanup) {
            cleanup()
        }
        // 将 onInvalidate 作为回调函数的第三个参数，以边用户使用
        cb(newValue, oldValue, onInvalidate)
        oldValue = newValue
    }

    const effectFn = effect(
        () => getter,
        {
            lazy: true,
            scheduler: () => {
                if (options.flush === 'post') {
                    const p = new Promise()
                    p.then(job)
                } else {
                    job()
                }
            }
        }
    )
}