Crystal For Rubyists
Search…
book
Chapter 8: Concurrency and Channels
Did you remember Chapter 1? We did a concurrent Hello World!
Here’s a quick reminder.
1
channel = Channel(String).new
2
10.times do
3
spawn {
4
channel.send "Hello?"
5
}
6
puts channel.receive
7
end
Copied!
In Crystal we use the keyword
spawn to make something work in the background without blocking the main execution.To achieve this
spawn creates a lightweight thread called Fiber. Fibers are very cheap to create and you can easily create tens of thousands of Fibers on a single core.Okay, that’s really cool! We can use
spawn to make stuff work in the background but how do we get something back from a Fiber.Now that’s where
Channels come to play.Channel
As the name stands a
Channel is a channel between a sender and the receiver. Therefore a Channel lets each other communicate with send and receive methods.Let’s take a line by line look at our previous example.
1
channel = Channel(String).new
Copied!
We create a
Channel with Channel(String).new. Note that we are creating a Channel which will send and receive messages with type of String.1
10.times do
2
spawn {
3
channel.send "Hello?"
4
}
5
puts channel.receive
6
end
Copied!
Leaving the loop aside, we are sending a message to our channel inside
spawn. You might ask ‘Why are we sending message in the background?’ Well, send is a blocking operation and if we do that in the main program we gonna block the program forever.Consider this:
1
channel = Channel(String).new
2
channel.send "Hello?" # This blocks the program execution
3
puts channel.receive
Copied!
What’s the output of this program? Actually this program won’t ever finish because it gets blocked by
channel.send "Hello?". Now that we know why we use spawn to send a message let’s continue.1
spawn {
2
channel.send "Hello?"
3
}
4
puts channel.receive
Copied!
We just sent a message through our channel in the background with
spawn. Then we receive it back with channel.receive. In this example the message is Hello? so this program prints Hello?and then finishes.book - Previous
Chapter 7: Types and Method Overloading
Next - book
Chapter 9: Macros and Metaprogramming
Last modified 2yr ago
Copy link
Contents
Channel