在Nim中实现setInterval/clearInterval及async proc返回proc类型问题
Nim runInterval 实现错误分析与修复
核心问题原因
你现有代码的问题来自两个逻辑和类型错误:
- 标记了
{.async.}的proc返回值永远是Future[T]类型,你直接调用runInterval拿到的是包裹了返回函数的Future,不是可直接调用的clear函数,所以调用失败。 return clearInterval写在了无限while循环之后,循环永远不会主动退出,返回逻辑永远不会执行,你不可能拿到终止函数。另外代码存在笔误:参数定义为interval,循环里错误使用了未定义的intv变量。
修复方案
调整实现逻辑,不需要把runInterval本身标记为async,而是内部启动异步任务,直接返回clear函数即可:
import asyncdispatch proc runInterval(cb: proc, interval: int): proc() = var stop_run = false # 内部异步执行循环逻辑,不阻塞返回 proc loop() {.async.} = while not stop_run: await sleepAsync(interval) if not stop_run: # 防止sleep期间被终止,多做一次校验避免多余执行 cb() asyncSpawn loop() # 直接返回终止函数 proc clearInterval() = stop_run = true return clearInterval proc in_interval() = echo "hahah" let clearInterval = runInterval(in_interval, 1000) # 测试用例:3秒后终止定时任务 proc stopAfter3s() {.async.} = await sleepAsync(3000) clearInterval() echo "定时任务已终止" asyncSpawn stopAfter3s() runForever()
关于async proc返回proc类型的规则说明
你原本的类型标注写法本身是合法的,如果你确实要写返回值为proc类型的async proc,需要先await这个Future才能拿到里面的proc,示例如下:
proc demo(): Future[proc()] {.async.} = proc test() = echo "test" return test # 调用时需要先await拿内部的proc proc useDemo() {.async.} = let testProc = await demo() testProc()
但该写法完全不适合定时任务场景,因为你不可能等待无限循环结束再获取终止函数。
内容的提问来源于stack exchange,提问作者georgehu
相关产品推荐
相关产品推荐

