文件名称：gen_stage:制片人和消费者演员对Elixir有背压
文件大小：72KB
文件格式：ZIP
更新时间：2024-05-28 01:48:58
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)