第八章：并发和管道

还记得第一章吗，我们写了一个并发的 Hello World，回顾一下:

channel = Channel(String).new
10.times do
  spawn {
    channel.send "Hello?"
  }
  puts channel.receive
end

在 Crystal 中我们用关键字 spawn 在后台运行而不阻塞主线程。 为了达到这样的目的，spawn 创建了一个轻量级线程名叫 Fiber，Fiber 创建成本非常低，你可以在一个单核上创建上万条 Fiber。 Ok，既然我们可以让 Fiber 后台运行，那如果我们想要 Fiber 返回值呢，这时管道 (Channel) 就派上用场了

管道 Channel

顾名思义，Channel 就是一根发送者和接受者之间的管道，所以 Channel 可以通过 send 和 receive 方法进行通信，让我们一步一步的分析上面的例子：

channel = Channel(String).new

我们用 Channel(String).new 创建一个管道，需要注意的是我们正在创建一个将会 send 和 receive 字符串类型的消息的管道。

10.times do
  spawn {
    channel.send "Hello?"
  }
  puts channel.receive
end

我们先不看循环，我们正 spawn 中向管道发送数据，你可能会问 “为什么我们要在后台发送数据？”，send 方法是一种阻塞操作，如果我们在主进程里面使用它就会永远锁死整个程序。看下这个:

channel = Channel(String).new
channel.send "Hello?" # This blocks the program execution
puts channel.receive

上面的程序的输出是什么呢？实际上这个程序并没有执行完，因为它被 channel.send "Hello?" 阻塞了，好了我们现在知道为什么用 spawn 发送消息了，继续！

spawn {
  channel.send "Hello?"
}
puts channel.receive

我们只是用 spawn 在后台中通过管道发送了一个信息.然后我们用 channel.receive 接受它的返回，这个例子中消息是 Hello?，所以程序打印 Hello? 并结束。