gen_stage:制片人和消费者演员对Elixir有背压

时间:2021-05-08 08:02:18
【文件属性】:
文件名称:gen_stage:制片人和消费者演员对Elixir有背压
文件大小:72KB
文件格式:ZIP
更新时间:2021-05-08 08:02:18
Elixir GenStage GenStage是用于在生产者和消费者之间交换事件的规范。 该项目当前提供以下功能: GenStage ( )-实施生产者和消费者阶段的行为 ConsumerSupervisor ( )-主管,用于使用GenStage中的事件并为每个事件启动子进程 您可能也会对基于GenStage的其他两个项目感兴趣: 为建设使用的map-reduce计算流量,隔板,窗,多指同时进行。 请参阅的文档或介绍GenStage和Flow背后的主要概念 用于构建并发和多阶段数据提取和数据处理管道的 ,以使用来自Amazon SQS,RabbitMQ等的事件。 请参阅或 例子 在目录中可以找到使用GenStage和ConsumerSupervisor的: 建立A -> B -> C阶段的管道并让事件流过的简单示例 有关如何使用一个或多个ConsumerSupervisor作为生产者(
【文件预览】:
gen_stage-master
----mix.exs(838B)
----.github()
--------workflows()
----lib()
--------consumer_supervisor.ex(29KB)
--------gen_stage()
--------gen_stage.ex(95KB)
----examples()
--------gen_event.exs(3KB)
--------producer_consumer.exs(2KB)
--------consumer_supervisor.exs(2KB)
--------rate_limiter.exs(2KB)
----.formatter.exs(118B)
----test()
--------gen_stage()
--------consumer_supervisor_test.exs(34KB)
--------gen_stage_test.exs(69KB)
--------test_helper.exs(42B)
----README.md(2KB)
----mix.lock(1KB)
----.gitignore(46B)
----CHANGELOG.md(8KB)

网友评论