【文件属性】:
文件名称:parallel.cr:水晶作为碎片的平行性
文件大小:6KB
文件格式:ZIP
更新时间:2021-05-19 03:39:05
Crystal
并行
并行是一个分片,它提供用于并行性的工具,类似于Crystal提供的用于并行的工具。 它提供了使用过程的光纤和通道的类似物,以及在过程之间进行通信的特殊类型的通道。
安装
将此添加到应用程序的shard.yml :
dependencies :
parallel :
github : RX14/parallel.cr
用法
在以下示例中,您希望在3秒内完成任务,因为它一次处理4个作业。 但是,当前Crystal一次只能在单个内核上执行代码,并且将花费整整12秒的时间来执行。
lib LibC
fun sleep ( seconds : UInt )
end
def do_work ( job )
LibC .sleep( 1 )
job * 2
end
def worker (in_channel, out_channel)
loop do
【文件预览】:
parallel.cr-master
----.travis.yml(18B)
----shard.yml(99B)
----LICENSE(1KB)
----TODO.md(164B)
----src()
--------parallel.cr(100B)
--------pchan.cr(2KB)
----examples()
--------example.cr(553B)
----spec()
--------pchan_spec.cr(1KB)
--------parallel_spec.cr(126B)
--------spec_helper.cr(393B)
----.gitignore(141B)
----README.md(2KB)
----.editorconfig(137B)