如何使用Clojure Core Async调度相隔`n`秒的函数列表
Clojure Core Async是Clojure语言中的一个核心库，用于实现异步编程和事件驱动的编程模式。它提供了一种简洁且强大的方式来调度函数的执行，包括在指定延迟后执行函数列表。
要使用Clojure Core Async调度相隔n秒的函数列表，可以按照以下步骤进行：
步骤1：导入Clojure Core Async库 在Clojure项目中的代码文件中，首先需要导入Clojure Core Async库，以便使用其中提供的函数和宏。可以使用以下代码进行导入：
(ns my-project.core
(:require [cljs.core.async :as async]))步骤2：定义异步函数 接下来，需要定义需要在指定延迟后执行的函数列表。这些函数可以是任意Clojure函数。
(defn my-function []
(println "This is my function"))步骤3：创建一个Core Async通道 Core Async通过通道（channel）来处理异步事件。在这里，我们需要创建一个通道来存储将要执行的函数。
(def my-channel (async/chan))步骤4：将函数添加到通道中
使用Core Async的put!函数，将要执行的函数添加到通道中，并指定延迟的时间。
(async/put! my-channel [my-function] (async/timeout (* 1000 n)))上述代码中，n表示相隔的秒数。(* 1000 n)是将秒转换为毫秒的表达式。
步骤5：定义调度函数 创建一个函数，用于从通道中读取待执行的函数，并调用它们。
(defn schedule-functions []
(async/go-loop []
(let [[f delay] (<! my-channel)]
(do
(<! (async/timeout delay))
(f)
(recur)))))上述代码中，schedule-functions函数使用了Core Async的go-loop宏，它可以创建一个无限循环并在每次迭代中从通道中获取函数并执行它们。
步骤6：启动调度函数
最后，可以在需要调度函数的地方调用schedule-functions函数来启动调度。
(schedule-functions)完整的代码示例如下：
(ns my-project.core
(:require [cljs.core.async :as async]))
(defn my-function []
(println "This is my function"))
(def my-channel (async/chan))
(async/put! my-channel [my-function] (async/timeout (* 1000 n)))
(defn schedule-functions []
(async/go-loop []
(let [[f delay] (<! my-channel)]
(do
(<! (async/timeout delay))
(f)
(recur)))))
(schedule-functions)这样就可以使用Clojure Core Async调度相隔n秒的函数列表了。每个函数都会在指定的延迟后被执行。
关于Clojure Core Async的更多详细信息和用法，请参考腾讯云的相关产品和文档：
- Clojure Core Async文档：https://docs.tencentyun.com/product/Clojure_Core_Async
- 腾讯云云计算产品：https://cloud.tencent.com/product
相关·内容
在我的Clojure项目中，我正在尝试创建对一个API的http调用列表，该API具有一个速率限制器，该限制器仅允许每分钟进行n调用。我希望在所有http调用完成后返回每个响应，以便进一步处理。我刚接触Clojure的核心异步，但我认为它会很适合，但因为我需要每次调用n的时间间隔几秒，所以我也在尝试使用Chime库。在Chime的库中，它有使用Core A
浏览 56提问于2021-03-06得票数 2
回答已采纳
2回答
在将clojure 1.7.0-alpha 5升级到任何以后的版本后，由于延迟序列的chunking，代码会出现中断。我写了一个例子来说明这个问题： [] (lazy-seq(defn unchunk [s]
(when (seq
浏览 5提问于2016-12-13得票数 1
回答已采纳
是否可以在Clojure中使用ClojureScript的基于状态机的core.async实现，而不是Clojure的基于线程的实现？我希望能够在JVM上使用core.async，但不使用线程。
浏览 5提问于2014-02-12得票数 4
回答已采纳
1回答
我正在包装一个Javascript库，每当一个新的日志条目到达时，它就会给我一个回调。(.on my-logs-source "log-entry" handle-log-event)
我想对这些事件执行一些简单的聚合，比如clojure的partition-by函数，它返回换能器，并得到结果的向量将事件回调流转换为我可以应用传感器的东西的惯用方法是什么？
浏览 1提问于2017-03-25得票数 2
回答已采纳
for each input: HTTP request B我使用的是客户端Http-kit使用Java (参见和)我尝试过三种方法：
浏览 7提问于2016-03-10得票数 10
我只是想用Clojure写一个简单的小猜谜游戏，我得到了这个错误。我看不出字符在哪里被当作函数处理，因为结果输入也表明应该不会有这样的问题。代码如下： (:gen-class))
(if(= n 0) () (cons (first x) (takeFst (rest x) (-
浏览 2提问于2017-12-18得票数 0
我使用的是表单，我使用的是，而对于大型循环，我仍然得到堆栈溢出。我的Clojure版本是1.5.1。
上下文:我正在训练一个神经网络来模仿异或。函数xor是前馈函数，获取权重并输入并返回结果；函数b-xor是向后传播函数，它在上次调用xor的结果下返回更新的权重。在每次对weights的调用中都会使用整个xor。那么，为什么我可以在内部使
浏览 5提问于2013-09-19得票数 7
回答已采纳
1回答
我正在试验Python3.4的异步模块。由于没有使用异步的MongoDB现成包，所以我编写了一个小包装类，它在执行器中执行所有mongo查询。_client[db]))
我希望异步执行inserts，这意味着执行它们的coroutine不希望等待执行完成。当我yield from这个协同线而不是使用asyncio.async运行它时，我可以看到这一行。然而，真正奇怪的是，当我使用MongoDB运行这个测试条目时，测试条目实际上存在于asyncio.<e
浏览 2提问于2014-04-20得票数 6
4回答
对于一个工人，他一次只能执行一个任务(但可以立即在任务之间切换)--定义为"n秒，每隔m秒“(例如，每3600秒5秒)如果是“每4秒1秒”和“每
浏览 0提问于2008-10-18得票数 3
我试图在Clojure中重写这个锈蚀代码： let nums = [1, 2]; });}(def noms ["Tim", "Eston", "Aaron",
浏览 2提问于2014-11-18得票数 3
我已经以懒惰序列的形式编写了一个解决方案，但它超级慢，而我在web上找到的另一个解决方案(链接如下)，基本上做同样的事情只需要不到一秒钟的时间。我是clojure和lazy序列的新手，所以我使用take-while、lazy-cat rest或map可能是罪魁祸首。你能看一下我的代码吗?如果你看到什么，请告诉我。运行时间不到一秒的解决方案是：
它不使用惰性序列。我想知道为什么它这么
浏览 0提问于2016-01-18得票数 0
有一件事我有点困惑，那就是clojure require语句中括号和括号之间的区别。我想知道是否有人能给我解释一下。例如，这两个命令做的是相同的事情： (:gen-class)和 (:gen-class)
(:require '
浏览 0提问于2013-04-09得票数 16
回答已采纳
6回答
以字符串形式获取堆栈跟踪
、、、
我正在使用Clojure，我想获得一个可以记录的堆栈跟踪(理想情况下，我希望以字符串的形式获得它)。我看到(.getStackTrace e)返回一个StackTraceElement[]，但是我不知道如何打印出有意义的东西。我的第二种方法是使用PrintWriter作为参数的(.printStackTrace e) (因为我知道这在Java语言中是可能的)，但是我似乎没有得到正确的语法。
谢谢。
浏览 3提问于2013-06-26得票数 13
回答已采纳
我正在尝试使用Clojure doc函数获取文档，但无法从REPL获得文档(我使用的是Emacs和SLIME)。If coll is nil, returns nil.user> @kotarak发表了最相关的评论：“注意，clojure.core/doc是1.2及
浏览 0提问于2011-06-22得票数 5
回答已采纳
我设想这样做的一种方法是: 1.使用slurp on (io/file file-name.clj)生成一个包含文件内容的字符串；2.将该字符串传递给一个解析器，用于Clojure代码；3.将解析器产生的序列注入列表有没有人知道用一种更优雅和/或惯用的方式来读取Clojure文件作为S-表达式的列表？更新:根据评论部分的反馈，我决定尝试在实际源文件中使用
浏览 4提问于2016-10-11得票数 1
回答已采纳
1回答
我想知道如何在clojure中创建n个线程。有一个叫做“估计值”的函数，它可以估计一个值并返回结果。现在我想使用pmap或pcalls来创建n个线程，每个线程可以计算一个估计值，然后组合n个结果并返回最终的估计值。我的代码是 (/ (apply + (pmap (estimate-value) (range n)))
浏览 4提问于2016-05-04得票数 1
回答已采纳
2回答
所以我认为命名一个计算指数^的函数是个不错的主意，但是看起来插入符号实际上做了一些特别的事情，因为Clojure REPL在计算'^时会生成一个错误。谷歌搜索给我的主要是，所以我想知道在Clojure中插入符号的实际用途是什么。
(另外，是否可以将函数命名为^?)
浏览 0提问于2012-01-19得票数 35
回答已采纳
我在这里肯定遗漏了一些非常明显的东西，但我正在尝试设置一个非常基本的程序，将一个项目放到一个通道上，然后阻塞，直到我可以再次取下它。整个方案如下： (:require [cljs.core.async :as async :refer [>!! <!! put! chan <!c))Uncaught TypeError: Cannot call method '
浏览 1提问于2014-01-28得票数 15
回答已采纳
我正在从clojure函数生成emacs elisp代码。我最初使用的是一个反宏，但我意识到，由于我要跨平台，并且必须手动地将代码执行到elisp环境中，所以我可以很容易地使用一个标准的clojure函数。但基本上我所做的是非常宏观的。`(~f0 ~f1 ~f2)这将生成一个包含两个函数定义的列表--生成的elisp和一个单
浏览 5提问于2015-03-06得票数 3
回答已采纳
经过一段时间的工作，我已经积累了一些关于它懒惰的知识。我知道经常使用的API (如map )是否懒惰。然而，当我开始使用一个不熟悉的API (比如with-open )时，我仍然感到怀疑。是否有文档显示Clojure的核心模块的惰性API的完整列表？
浏览 0提问于2016-02-04得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
