在 clojure core.async go-loop 中工作的方式有哪些权衡?

2023-12-25

当我编写更多 core.async 代码时,出现的一种非常常见的模式是循环,它在一系列通道上进行切换并执行一些工作来响应消息,例如:

(go-loop [state {}]
  (let [[value task] (alts! tasks)]
    ...work...
    (recur state))

不过,我觉得我不理解我实际上可以完成这项工作的各种方式的权衡,所以我想我应该尝试在这里探索它们。

  • 内联或通过调用函数:这会阻止循环继续,直到工作完成。由于它位于 go 块中,因此不想执行 I/O 或锁定操作。
  • >!发送给工作人员监控的通道的消息:如果通道已满,则会通过停车来阻塞循环,直到通道有容量为止。这允许线程做其他工作并允许背压。
  • >!!一条消息:如果通道已满,则会通过休眠运行 go 循环的线程来阻塞。这可能是不可取的,因为 go 线程是严格有限的资源。
  • >!另一个 go 块中的消息:这几乎会立即成功,除非没有可用的 go 线程。相反,如果通道已满并且消耗缓慢,则可能会在短时间内导致系统的 go 线程匮乏。
  • >!!带有线程块​​的消息:与 go 块类似,但消耗系统线程而不是 go 线程,因此上限可能更高
  • 投入!一条消息:尚不清楚权衡是什么
  • 在 future 中调用工作函数:将工作交给 clojure 代理池中的线程来完成,允许 go 循环继续。如果输入速率超过输出速率,则会无限制地增加代理池队列。

这个总结是否正确、全面?


如果要完成的工作完全受 CPU 限制,那么我可能会在go块,除非它是一个可能需要很长时间的操作并且我想要go阻止继续响应其他消息。

一般来说,任何不阻塞、睡眠或执行 I/O 的工作都可以安全地放入go块而不会对系统的吞吐量产生重大影响。

您可以使用>!将工作提交给一个或一组工人。我几乎永远不会使用>!! in a go阻塞,因为它可以阻塞分配给运行的有限数量的线程之一go blocks.

当您需要执行 I/O 或可能需要长时间运行的计算时,请使用thread代替go。这非常类似于future- 它创建一个真正的线程 - 但它返回一个通道,例如go.

put!是一个较低级别的操作,通常在 core.async 的“边界”使用,将其连接到传统的基于回调的接口。很少有任何理由使用put!里面一个go.

core.async 可以支持对线程创建方式的细粒度控制。我在博客文章中演示了一些可能性,使用 core.async 进行并行处理 http://stuartsierra.com/2013/12/08/parallel-processing-with-core-async.

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

在 clojure core.async go-loop 中工作的方式有哪些权衡? 的相关文章

随机推荐

  • Django 发送电子邮件:SMTPServerDisconnected:连接意外关闭

    你好 我想发送电子邮件激活使用 django 注册 redux 这是我的设置 py EMAIL BACKEND django core mail backends smtp EmailBackend ACCOUNT ACTIVATION D
  • scala 宏:延迟类型推断

    序言 这是基于 Travis Brown 的基于宏的解决方案 https stackoverflow com a 13447439 185840复制案例类属性 Given trait Entity E lt Entity E self E
  • PyYAML :控制 yaml.load() 调用的项目的顺序

    我有一个 yaml 设置文件 它在数据库中创建一些记录 setting1 name item item name1 text anothersetting2 name item item sub setting name item item
  • 将动态 JSON 值解析为 Java 对象

    在我的应用程序中 我有很多具有排序和过滤功能的概述 表格 由于不同的列可以保存不同的值类型 字符串 数字 日期 集合等 因此这些列的过滤器也可以带来不同的值 让我向您展示一些示例 已转换为 JSON 通过 REST 请求发送到服务器 对于简
  • XE7更新1和iOS 8.1模拟器不工作

    在 Delphi XE7 中将目标设置为 iOS 8 1 Simulator 时 应用程序崩溃 它部署得很好 也可以运行 但是 firemonkey 启动屏幕仍然打开并且永远不会完成加载 这种情况发生在一个普通的新移动应用程序中 只在表单中
  • SignalR:生成的代理与动态创建的集线器文件

    SignalR 集线器代理生成器的输出与动态生成的集线器代理文件本质上相同吗 如果不是 有什么区别 我的问题的一些背景 由于执行期间的依赖性问题 我正在努力使用命令行工具创建集线器代理 并且我确实认为获取动态生成的文件可能是一种更简单的方法
  • 限制 Visual Studio 的编辑区域仅显示一个函数或方法

    几年前 当我使用 VB 6 时 我可以让编辑器窗口只显示我正在处理的函数 方法 我怀念这一点 有没有一种方法 一个插件 或者一个黑客 可以让我现在做同样的事情 Thanks 看来此功能已被删除 而且没有办法解决这个问题 也许您可 以考虑为
  • ValueError:无法解析相关模型u'mutech.branch'

    我正在尝试在 models py 文件中创建外键 但是在运行 python manage py migrate 命令时 我收到以下错误 之前一切都很好 即使我撤消了所有更改 它仍然给出相同的错误 我也尝试删除我的数据库 但没有任何效果 Ap
  • SKPhysicsBody 不符合预期

    我有以下代码来创建一个矩形砖块和一个与其关联的物理体 我预计物理主体是一个与砖块相同大小和位置的实心矩形 但我得到的主体有一个位置偏移 也许还有尺寸差异 我错过的坐标系是否存在问题 解决这个问题的正确方法是什么 void addBrick
  • 跨多个区域部署 Firebase Cloud Functions

    我想跨多个区域部署相同的云功能 有简单的方法吗 由于您没有说明要部署什么类型的函数 因此我假设 https 函数 将任何其他类型的 后台 功能部署到多个区域是没有意义的 因为每个区域都可能触发每个事件 这将相当混乱 使用 https 函数
  • 当提供正则表达式时,Java 中的 String.split() 方法到底如何工作?

    我正在准备 OCPJP 考试 遇到以下示例 class Test public static void main String args String test I am preparing for OCPJP String tokens
  • UITableView 中替代单元格的不同高度

    如何制作具有不同高度的备用单元 我需要 cell1 的高度为 60 cell2 的高度为 30 我怎样才能做到这一点 提前致谢 您可以通过表视图的委托方法设置单元格的高度 CGFloat tableView UITableView tabl
  • 如何为 JSON 对象设置原型?

    我正在从服务器接收一些 JSON 对象 并且我想将其 类型转换 或 祝福 为具有已定义方法的对象 有没有办法为普通 JSON 对象设置原型 function MyClass someValue this myProperty someVal
  • Firefox 3 窗口焦点和模糊

    窗口 blur 函数 窗口焦点 假 焦点 函数 窗口焦点 真 问题是 在 Firefox 3 中 当我创建新选项卡时 它不会丢失窗口焦点 而在ff2 ie7中确实输了 在 ff3 中 当我选择另一个程序时 它只会失去窗口焦点 有人有解决这个
  • 为什么 reshape2 融化对我来说返回值 = NA?

    为什么重塑2melt return value NA for me 它对我来说适用于 reshape 但不适用于 reshape2 这是一个示例数据文件 station id year month day h1 h2 h3 h4 h5 h6
  • 无法使用 CDK + Lambda 捆绑资产错误

    我有这个项目结构 其中control是我的项目的名称和根 control src control loader gt this has a function inside called also control loader utils s
  • 使用日期时间时 matplotlib“axis.invert_xaxis”崩溃

    如果我运行以下代码 import pandas as pd from datetime import datetime import numpy as np import matplotlib pyplot as plt df pd Dat
  • 如何按时间段对DataFrame进行分组?

    我有来自日志文件的一些数据 并希望按分钟对条目进行分组 def gen date count 10 while count gt 0 yield date event format randint 1 9 source format ran
  • PHP从列表中随机选择

    我目前正在使用随机选择颜色的 PHP 代码 div style background none class post bg thickbox div
  • 在 clojure core.async go-loop 中工作的方式有哪些权衡?

    当我编写更多 core async 代码时 出现的一种非常常见的模式是循环 它在一系列通道上进行切换并执行一些工作来响应消息 例如 go loop state let value task alts tasks work recur sta