Permalink
Cannot retrieve contributors at this time
Fetching contributors…
| <!DOCTYPE html> | |
| <html> | |
| <head> | |
| <meta charset="utf-8"> | |
| <title>Go by Example: Non-Blocking Channel Operations</title> | |
| <link rel=stylesheet href="site.css"> | |
| </head> | |
| <script type="text/javascript"> | |
| if (window.location.host == "gobyexample.com") { | |
| var _gaq = _gaq || []; | |
| _gaq.push(['_setAccount', 'UA-34996217-1']); | |
| _gaq.push(['_trackPageview']); | |
| (function() { | |
| var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; | |
| ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; | |
| var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); | |
| })(); | |
| } | |
| </script> | |
| <body> | |
| <div class="example" id="non-blocking-channel-operations"> | |
| <h2><a href="./">Go by Example</a>: Non-Blocking Channel Operations</h2> | |
| <table> | |
| <tr> | |
| <td class="docs"> | |
| <p>Basic sends and receives on channels are blocking. | |
| However, we can use <code>select</code> with a <code>default</code> clause to | |
| implement <em>non-blocking</em> sends, receives, and even | |
| non-blocking multi-way <code>select</code>s.</p> | |
| </td> | |
| <td class="code empty leading"> | |
| </td> | |
| </tr> | |
| <tr> | |
| <td class="docs"> | |
| </td> | |
| <td class="code leading"> | |
| <a href="http://play.golang.org/p/M972dltae2"><img title="Run code" src="play.png" class="run" /></a> | |
| <div class="highlight"><pre><span class="kn">package</span> <span class="nx">main</span> | |
| </pre></div> | |
| </td> | |
| </tr> | |
| <tr> | |
| <td class="docs"> | |
| </td> | |
| <td class="code leading"> | |
| <div class="highlight"><pre><span class="kn">import</span> <span class="s">"fmt"</span> | |
| </pre></div> | |
| </td> | |
| </tr> | |
| <tr> | |
| <td class="docs"> | |
| </td> | |
| <td class="code leading"> | |
| <div class="highlight"><pre><span class="kd">func</span> <span class="nx">main</span><span class="p">()</span> <span class="p">{</span> | |
| <span class="nx">messages</span> <span class="o">:=</span> <span class="nb">make</span><span class="p">(</span><span class="kd">chan</span> <span class="kt">string</span><span class="p">)</span> | |
| <span class="nx">signals</span> <span class="o">:=</span> <span class="nb">make</span><span class="p">(</span><span class="kd">chan</span> <span class="kt">bool</span><span class="p">)</span> | |
| </pre></div> | |
| </td> | |
| </tr> | |
| <tr> | |
| <td class="docs"> | |
| <p>Here’s a non-blocking receive. If a value is | |
| available on <code>messages</code> then <code>select</code> will take | |
| the <code><-messages</code> <code>case</code> with that value. If not | |
| it will immediately take the <code>default</code> case.</p> | |
| </td> | |
| <td class="code leading"> | |
| <div class="highlight"><pre> <span class="k">select</span> <span class="p">{</span> | |
| <span class="k">case</span> <span class="nx">msg</span> <span class="o">:=</span> <span class="o"><-</span><span class="nx">messages</span><span class="p">:</span> | |
| <span class="nx">fmt</span><span class="p">.</span><span class="nx">Println</span><span class="p">(</span><span class="s">"received message"</span><span class="p">,</span> <span class="nx">msg</span><span class="p">)</span> | |
| <span class="k">default</span><span class="p">:</span> | |
| <span class="nx">fmt</span><span class="p">.</span><span class="nx">Println</span><span class="p">(</span><span class="s">"no message received"</span><span class="p">)</span> | |
| <span class="p">}</span> | |
| </pre></div> | |
| </td> | |
| </tr> | |
| <tr> | |
| <td class="docs"> | |
| <p>A non-blocking send works similarly.</p> | |
| </td> | |
| <td class="code leading"> | |
| <div class="highlight"><pre> <span class="nx">msg</span> <span class="o">:=</span> <span class="s">"hi"</span> | |
| <span class="k">select</span> <span class="p">{</span> | |
| <span class="k">case</span> <span class="nx">messages</span> <span class="o"><-</span> <span class="nx">msg</span><span class="p">:</span> | |
| <span class="nx">fmt</span><span class="p">.</span><span class="nx">Println</span><span class="p">(</span><span class="s">"sent message"</span><span class="p">,</span> <span class="nx">msg</span><span class="p">)</span> | |
| <span class="k">default</span><span class="p">:</span> | |
| <span class="nx">fmt</span><span class="p">.</span><span class="nx">Println</span><span class="p">(</span><span class="s">"no message sent"</span><span class="p">)</span> | |
| <span class="p">}</span> | |
| </pre></div> | |
| </td> | |
| </tr> | |
| <tr> | |
| <td class="docs"> | |
| <p>We can use multiple <code>case</code>s above the <code>default</code> | |
| clause to implement a multi-way non-blocking | |
| select. Here we attempt non-blocking receives | |
| on both <code>messages</code> and <code>signals</code>.</p> | |
| </td> | |
| <td class="code"> | |
| <div class="highlight"><pre> <span class="k">select</span> <span class="p">{</span> | |
| <span class="k">case</span> <span class="nx">msg</span> <span class="o">:=</span> <span class="o"><-</span><span class="nx">messages</span><span class="p">:</span> | |
| <span class="nx">fmt</span><span class="p">.</span><span class="nx">Println</span><span class="p">(</span><span class="s">"received message"</span><span class="p">,</span> <span class="nx">msg</span><span class="p">)</span> | |
| <span class="k">case</span> <span class="nx">sig</span> <span class="o">:=</span> <span class="o"><-</span><span class="nx">signals</span><span class="p">:</span> | |
| <span class="nx">fmt</span><span class="p">.</span><span class="nx">Println</span><span class="p">(</span><span class="s">"received signal"</span><span class="p">,</span> <span class="nx">sig</span><span class="p">)</span> | |
| <span class="k">default</span><span class="p">:</span> | |
| <span class="nx">fmt</span><span class="p">.</span><span class="nx">Println</span><span class="p">(</span><span class="s">"no activity"</span><span class="p">)</span> | |
| <span class="p">}</span> | |
| <span class="p">}</span> | |
| </pre></div> | |
| </td> | |
| </tr> | |
| </table> | |
| <table> | |
| <tr> | |
| <td class="docs"> | |
| </td> | |
| <td class="code"> | |
| <div class="highlight"><pre><span class="gp">$</span> go run non-blocking-channel-operations.go | |
| <span class="go">no message received</span> | |
| <span class="go">no message sent</span> | |
| <span class="go">no activity</span> | |
| </pre></div> | |
| </td> | |
| </tr> | |
| </table> | |
| <p class="next"> | |
| Next example: <a href="closing-channels">Closing Channels</a>. | |
| </p> | |
| <p class="footer"> | |
| by <a href="https://twitter.com/mmcgrana">@mmcgrana</a> | <a href="mailto:mmcgrana@gmail.com">feedback</a> | <a href="https://github.com/mmcgrana/gobyexample/blob/master/examples/non-blocking-channel-operations">source</a> | <a href="https://github.com/mmcgrana/gobyexample#license">license</a> | |
| </p> | |
| </div> | |
| </body> | |
| </html> |