{"id":15450,"date":"2024-11-18T18:06:16","date_gmt":"2024-11-18T10:06:16","guid":{"rendered":"https:\/\/fwq.ai\/blog\/?p=15450"},"modified":"2024-11-18T18:06:16","modified_gmt":"2024-11-18T10:06:16","slug":"goroutine%e5%92%8cchannel%e7%9a%84%e8%af%a6%e7%bb%86%e7%90%86%e8%a7%a3%ef%bc%88%e4%b8%89%ef%bc%89","status":"publish","type":"post","link":"https:\/\/fwq.ai\/blog\/15450\/","title":{"rendered":"Goroutine\u548cchannel\u7684\u8be6\u7ec6\u7406\u89e3\uff08\u4e09\uff09"},"content":{"rendered":"<ul>\n<li>\n<h2><strong>Go\u8bed\u8a00\u5e76\u53d1\u7684\u8bbe\u8ba1\u6a21\u5f0f\u548c\u5e94\u7528\u573a\u666f<\/strong><\/h2>\n<\/li>\n<\/ul>\n<p>\u4ee5\u4e0b\u8bbe\u8ba1\u6a21\u5f0f\u548c\u5e94\u7528\u573a\u666f\u6765\u81eaGoogle IO\u4e0a\u7684\u5173\u4e8eGoroutine\u7684PPT:https:\/\/talks.golang.org\/2012\/concurrency.slide<\/p>\n<p>\u672c\u6587\u7684\u793a\u4f8b\u4ee3\u7801\u5728:\u00a0https:\/\/github.com\/hit9\/Go-patterns-with-channel<\/p>\n<ul>\n<li><span id=\"more-2514\"><\/span><br \/>\n<h2><strong>\u751f\u6210\u5668<\/strong><\/h2>\n<\/li>\n<\/ul>\n<p>\u5728Python\u4e2d\u6211\u4eec\u53ef\u4ee5\u4f7f\u7528yield\u5173\u952e\u5b57\u6765\u8ba9\u4e00\u4e2a\u51fd\u6570\u6210\u4e3a\u751f\u6210\u5668\uff0c\u5728Go\u4e2d\u6211\u4eec\u53ef\u4ee5\u4f7f\u7528\u4fe1\u9053\u6765\u5236\u9020\u751f\u6210\u5668(\u4e00\u79cdlazy load\u7c7b\u4f3c\u7684\u4e1c\u897f)\u3002\u5f53\u7136\u6211\u4eec\u7684\u4fe1\u9053\u5e76\u4e0d\u662f\u7b80\u5355\u7684\u505a\u963b\u585e\u4e3b\u7ebf\u7684\u529f\u80fd\u6765\u4f7f\u7528\u7684\u54e6\u3002<\/p>\n<p>\u4e0b\u9762\u662f\u4e00\u4e2a\u5236\u4f5c\u81ea\u589e\u6574\u6570\u751f\u6210\u5668\u7684\u4f8b\u5b50\uff0c\u76f4\u5230\u4e3b\u7ebf\u5411\u4fe1\u9053\u7d22\u8981\u6570\u636e\uff0c\u6211\u4eec\u624d\u6dfb\u52a0\u6570\u636e\u5230\u4fe1\u9053<\/p>\n<pre>func xrange() chan int{ \/\/ xrange\u7528\u6765\u751f\u6210\u81ea\u589e\u7684\u6574\u6570\r\n\u00a0\u00a0\u00a0 var ch chan int = make(chan int)\r\n\u00a0\u00a0\u00a0 go func() { \/\/ \u5f00\u51fa\u4e00\u4e2agoroutine\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 for i := 0; ; i++ {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 ch &lt;- i\u00a0 \/\/ \u76f4\u5230\u4fe1\u9053\u7d22\u8981\u6570\u636e\uff0c\u624d\u628ai\u6dfb\u52a0\u8fdb\u4fe1\u9053\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0 }()\r\n\u00a0\u00a0\u00a0 return ch\r\n}\r\n\r\nfunc main() {\r\n\u00a0\u00a0\u00a0 generator := xrange()\r\n\u00a0\u00a0\u00a0 for i:=0; i &lt; 1000; i++ {\u00a0 \/\/ \u6211\u4eec\u751f\u62101000\u4e2a\u81ea\u589e\u7684\u6574\u6570\uff01\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 fmt.Println(&lt;-generator)\r\n\u00a0\u00a0\u00a0 }\r\n}<\/pre>\n<p>\u8fd9\u4e0d\u7981\u53eb\u6211\u60f3\u8d77\u4e86Python\u4e2d\u53ef\u7231\u7684xrange, \u6240\u4ee5\u7ed9\u4e86\u751f\u6210\u5668\u8fd9\u4e2a\u540d\u5b57\uff01<\/p>\n<ul>\n<li>\n<h2><strong>\u670d\u52a1\u5316<\/strong><\/h2>\n<\/li>\n<\/ul>\n<p>\u6bd4\u5982\u6211\u4eec\u52a0\u8f7d\u4e00\u4e2a\u7f51\u7ad9\u7684\u65f6\u5019\uff0c\u4f8b\u5982\u6211\u4eec\u767b\u5165\u65b0\u6d6a\u5fae\u535a\uff0c\u6211\u4eec\u7684\u6d88\u606f\u6570\u636e\u5e94\u8be5\u6765\u81ea\u4e00\u4e2a\u72ec\u7acb\u7684\u670d\u52a1\uff0c\u8fd9\u4e2a\u670d\u52a1\u53ea\u8d1f\u8d23\u8fd4\u56de\u67d0\u4e2a\u7528\u6237\u7684\u65b0\u7684\u6d88\u606f\u63d0\u9192\u3002\u5982\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528\u793a\u4f8b:<\/p>\n<pre>func get_notification(user string) chan string{\r\n\u00a0\u00a0 \/*\r\n\u00a0\u00a0\u00a0 * \u6b64\u5904\u53ef\u4ee5\u67e5\u8be2\u6570\u636e\u5e93\u83b7\u53d6\u65b0\u6d88\u606f\u7b49\u7b49..\r\n\u00a0\u00a0\u00a0 *\/\r\n\u00a0\u00a0\u00a0 notifications := make(chan string)\r\n\u00a0\u00a0\u00a0 go func() { \/\/ \u60ac\u6302\u4e00\u4e2a\u4fe1\u9053\u51fa\u53bb\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 notifications &lt;- fmt.Sprintf(\"Hi %s, welcome to weibo.com!\", user)\r\n\u00a0\u00a0\u00a0 }()\r\n\u00a0\u00a0\u00a0 return notifications\r\n}\r\n\r\nfunc main() {\r\n\u00a0\u00a0\u00a0 jack := get_notification(\"jack\") \/\/\u00a0 \u83b7\u53d6jack\u7684\u6d88\u606f\r\n\u00a0\u00a0\u00a0 joe := get_notification(\"joe\") \/\/ \u83b7\u53d6joe\u7684\u6d88\u606f\r\n\u00a0\u00a0\u00a0 \/\/ \u83b7\u53d6\u6d88\u606f\u7684\u8fd4\u56de\r\n\u00a0\u00a0\u00a0 fmt.Println(&lt;-jack)\r\n\u00a0\u00a0\u00a0 fmt.Println(&lt;-joe)\r\n}<\/pre>\n<ul>\n<li>\n<h2><strong>\u591a\u8def\u590d\u5408<\/strong><\/h2>\n<\/li>\n<\/ul>\n<p>\u4e0a\u9762\u7684\u4f8b\u5b50\u90fd\u4f7f\u7528\u4e00\u4e2a\u4fe1\u9053\u4f5c\u4e3a\u8fd4\u56de\u503c\uff0c\u53ef\u4ee5\u628a\u4fe1\u9053\u7684\u6570\u636e\u5408\u5e76\u5230\u4e00\u4e2a\u4fe1\u9053\u7684\u3002 \u4e0d\u8fc7\u8fd9\u6837\u7684\u8bdd\uff0c\u6211\u4eec\u9700\u8981\u6309\u987a\u5e8f\u8f93\u51fa\u6211\u4eec\u7684\u8fd4\u56de\u503c\uff08\u5148\u8fdb\u5148\u51fa\uff09\u3002<\/p>\n<p>\u5982\u4e0b\uff0c\u6211\u4eec\u5047\u8bbe\u8981\u8ba1\u7b97\u5f88\u590d\u6742\u7684\u4e00\u4e2a\u8fd0\u7b97 100-x , \u5206\u4e3a\u4e09\u8def\u8ba1\u7b97\uff0c \u6700\u540e\u7edf\u4e00\u5728\u4e00\u4e2a\u4fe1\u9053\u4e2d\u53d6\u51fa\u7ed3\u679c:<\/p>\n<pre>func do_stuff(x int) int { \/\/ \u4e00\u4e2a\u6bd4\u8f83\u8017\u65f6\u7684\u4e8b\u60c5\uff0c\u6bd4\u5982\u8ba1\u7b97\r\n\u00a0\u00a0\u00a0 time.Sleep(time.Duration(rand.Intn(10)) * time.Millisecond) \/\/\u6a21\u62df\u8ba1\u7b97\r\n\u00a0\u00a0\u00a0 return 100 - x \/\/ \u5047\u5982100-x\u662f\u4e00\u4e2a\u5f88\u8d39\u65f6\u7684\u8ba1\u7b97\r\n}\r\n\r\nfunc branch(x int) chan int{ \/\/ \u6bcf\u4e2a\u5206\u652f\u5f00\u51fa\u4e00\u4e2agoroutine\u505a\u8ba1\u7b97\u5e76\u628a\u8ba1\u7b97\u7ed3\u679c\u6d41\u5165\u5404\u81ea\u4fe1\u9053\r\n\u00a0\u00a0\u00a0 ch := make(chan int)\r\n\u00a0\u00a0\u00a0 go func() {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 ch &lt;- do_stuff(x)\r\n\u00a0\u00a0\u00a0 }()\r\n\u00a0\u00a0\u00a0 return ch\r\n}\r\n\r\nfunc fanIn(chs... chan int) chan int {\r\n\u00a0\u00a0\u00a0 ch := make(chan int)\r\n\u00a0\u00a0\u00a0 for _, c := range chs {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 \/\/ \u6ce8\u610f\u6b64\u5904\u660e\u786e\u4f20\u503c\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 go func(c chan int) {ch &lt;- &lt;- c}(c) \/\/ \u590d\u5408\r\n\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0 return ch\r\n}\r\n\r\nfunc main() {\r\n\u00a0\u00a0\u00a0 result := fanIn(branch(1), branch(2), branch(3))\r\n\u00a0\u00a0\u00a0 for i := 0; i &lt; 3; i++ {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 fmt.Println(&lt;-result)\r\n\u00a0\u00a0\u00a0 }\r\n}<\/pre>\n<ul>\n<li>\n<h2><strong>select\u76d1\u542c\u4fe1\u9053<\/strong><\/h2>\n<\/li>\n<\/ul>\n<p>Go\u6709\u4e00\u4e2a\u8bed\u53e5\u53eb\u505aselect\uff0c\u7528\u4e8e\u76d1\u6d4b\u5404\u4e2a\u4fe1\u9053\u7684\u6570\u636e\u6d41\u52a8\u3002<\/p>\n<p>\u5982\u4e0b\u7684\u7a0b\u5e8f\u662fselect\u7684\u4e00\u4e2a\u4f7f\u7528\u4f8b\u5b50\uff0c\u6211\u4eec\u76d1\u89c6\u4e09\u4e2a\u4fe1\u9053\u7684\u6570\u636e\u6d41\u51fa\u5e76\u6536\u96c6\u6570\u636e\u5230\u4e00\u4e2a\u4fe1\u9053\u4e2d\u3002<\/p>\n<pre>func foo(i int) chan int {\r\n\u00a0\u00a0\u00a0 c := make(chan int)\r\n\u00a0\u00a0\u00a0 go func () { c &lt;- i }()\r\n\u00a0\u00a0\u00a0 return c\r\n}\r\n\r\nfunc main() {\r\n\u00a0\u00a0\u00a0 c1, c2, c3 := foo(1), foo(2), foo(3)\r\n\u00a0\u00a0\u00a0 c := make(chan int)\r\n\u00a0\u00a0\u00a0 go func() { \/\/ \u5f00\u4e00\u4e2agoroutine\u76d1\u89c6\u5404\u4e2a\u4fe1\u9053\u6570\u636e\u8f93\u51fa\u5e76\u6536\u96c6\u6570\u636e\u5230\u4fe1\u9053c\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 for {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 select { \/\/ \u76d1\u89c6c1, c2, c3\u7684\u6d41\u51fa\uff0c\u5e76\u5168\u90e8\u6d41\u5165\u4fe1\u9053c\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 case v1 := &lt;- c1: c &lt;- v1\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 case v2 := &lt;- c2: c &lt;- v2\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 case v3 := &lt;- c3: c &lt;- v3\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0 }()\r\n\u00a0\u00a0\u00a0 \/\/ \u963b\u585e\u4e3b\u7ebf\uff0c\u53d6\u51fa\u4fe1\u9053c\u7684\u6570\u636e\r\n\u00a0\u00a0\u00a0 for i := 0; i &lt; 3; i++ {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 fmt.Println(&lt;-c) \/\/ \u4ece\u6253\u5370\u6765\u770b\u6211\u4eec\u7684\u6570\u636e\u8f93\u51fa\u5e76\u4e0d\u662f\u4e25\u683c\u76841,2,3\u987a\u5e8f\r\n\u00a0\u00a0\u00a0 }\r\n}<\/pre>\n<p>\u6709\u4e86select, \u6211\u4eec\u5728 \u591a\u8def\u590d\u5408\u4e2d\u7684\u793a\u4f8b\u4ee3\u7801\u4e2d\u7684\u51fd\u6570fanIn\u8fd8\u53ef\u4ee5\u8fd9\u4e48\u6765\u5199(\u8fd9\u6837\u5c31\u4e0d\u7528\u5f00\u597d\u51e0\u4e2agoroutine\u6765\u53d6\u6570\u636e\u4e86):<\/p>\n<pre>func fanIn(branches ... chan int) chan int {\r\n\u00a0\u00a0\u00a0 c := make(chan int)\r\n\u00a0\u00a0\u00a0 go func() {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 for i := 0 ; i &lt; len(branches); i++ { \/\/select\u4f1a\u5c1d\u8bd5\u7740\u4f9d\u6b21\u53d6\u51fa\u5404\u4e2a\u4fe1\u9053\u7684\u6570\u636e\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 select {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 case v1 := &lt;- branches[i]: c &lt;- v1\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0 }()\r\n\u00a0\u00a0\u00a0 return c\r\n}<\/pre>\n<p>\u4f7f\u7528select\u7684\u65f6\u5019\uff0c\u6709\u65f6\u9700\u8981\u8d85\u65f6\u5904\u7406, \u5176\u4e2d\u7684timeout\u4fe1\u9053\u76f8\u5f53\u6709\u8da3:<\/p>\n<pre>timeout := time.After(1 * time.Second) \r\n\/\/ timeout \u662f\u4e00\u4e2a\u8ba1\u65f6\u4fe1\u9053, \u5982\u679c\u8fbe\u5230\u65f6\u95f4\u4e86\uff0c\u5c31\u4f1a\u53d1\u4e00\u4e2a\u4fe1\u53f7\u51fa\u6765\r\nfor is_timeout := false; !is_timeout; {\r\n\u00a0\u00a0\u00a0 select { \/\/ \u76d1\u89c6\u4fe1\u9053c1, c2, c3, timeout\u4fe1\u9053\u7684\u6570\u636e\u6d41\u51fa\r\n\u00a0\u00a0\u00a0 case v1 := &lt;- c1: fmt.Printf(\"received %d from c1\", v1)\r\n\u00a0\u00a0\u00a0 case v2 := &lt;- c2: fmt.Printf(\"received %d from c2\", v2)\r\n\u00a0\u00a0\u00a0 case v3 := &lt;- c3: fmt.Printf(\"received %d from c3\", v3)\r\n\u00a0\u00a0\u00a0 case &lt;- timeout: is_timeout = true \/\/ \u8d85\u65f6\r\n\u00a0\u00a0\u00a0 }\r\n}<\/pre>\n<ul>\n<li>\n<h2>\u7ed3\u675f\u6807\u5fd7<\/h2>\n<\/li>\n<\/ul>\n<p>\u5728Go\u5e76\u53d1\u4e0e\u5e76\u884c\u7b14\u8bb0\u4e00\u6211\u4eec\u5df2\u7ecf\u8bb2\u8fc7\u4fe1\u9053\u7684\u4e00\u4e2a\u5f88\u91cd\u8981\u4e5f\u5f88\u5e73\u5e38\u7684\u5e94\u7528\uff0c\u5c31\u662f\u4f7f\u7528\u65e0\u7f13\u51b2\u4fe1\u9053\u6765\u963b\u585e\u4e3b\u7ebf\uff0c\u7b49\u5f85goroutine\u7ed3\u675f\u3002<\/p>\n<p>\u8fd9\u6837\u6211\u4eec\u4e0d\u5fc5\u518d\u4f7f\u7528timeout\u3002<\/p>\n<p>\u90a3\u4e48\u5bf9\u4e0a\u9762\u7684timeout\u6765\u7ed3\u675f\u4e3b\u7ebf\u7684\u65b9\u6848\u4f5c\u4e2a\u66f4\u65b0\uff1a<\/p>\n<pre>func main() {\r\n\u00a0\u00a0\u00a0 c, quit := make(chan int), make(chan int)\r\n\u00a0\u00a0\u00a0 go func() {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 c &lt;- 2\u00a0 \/\/ \u6dfb\u52a0\u6570\u636e\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 quit &lt;- 1 \/\/ \u53d1\u9001\u5b8c\u6210\u4fe1\u53f7\r\n\u00a0\u00a0\u00a0 } ()\r\n\u00a0\u00a0\u00a0 for is_quit := false; !is_quit; {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 select { \/\/ \u76d1\u89c6\u4fe1\u9053c\u7684\u6570\u636e\u6d41\u51fa\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 case v := &lt;-c: fmt.Printf(\"received %d from c\", v)\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 case &lt;-quit: is_quit = true \/\/ quit\u4fe1\u9053\u6709\u8f93\u51fa\uff0c\u5173\u95edfor\u5faa\u73af\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0 }\r\n}<\/pre>\n<ul>\n<li>\n<h2><strong>\u83ca\u82b1\u94fe<\/strong><\/h2>\n<\/li>\n<\/ul>\n<p><a href=\"http:\/\/fwq.ai\/wp-content\/uploads\/2017\/08\/gophereartrumpet.jpg\"><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-15451\" src=\"https:\/\/fwq.ai\/blog\/wp-content\/uploads\/2024\/11\/gophereartrumpet.jpg\" width=\"900\" height=\"314\" srcset=\"https:\/\/fwq.ai\/blog\/wp-content\/uploads\/2024\/11\/gophereartrumpet.jpg 900w, https:\/\/fwq.ai\/blog\/wp-content\/uploads\/2024\/11\/gophereartrumpet-300x105.jpg 300w, https:\/\/fwq.ai\/blog\/wp-content\/uploads\/2024\/11\/gophereartrumpet-768x268.jpg 768w, https:\/\/fwq.ai\/blog\/wp-content\/uploads\/2024\/11\/gophereartrumpet-670x234.jpg 670w\" sizes=\"auto, (max-width: 900px) 100vw, 900px\" title=\"Goroutine\u548cchannel\u7684\u8be6\u7ec6\u7406\u89e3\uff08\u4e09\uff09\u63d2\u56fe\" alt=\"Goroutine\u548cchannel\u7684\u8be6\u7ec6\u7406\u89e3\uff08\u4e09\uff09\u63d2\u56fe\" \/><\/a><\/p>\n<p>\u7b80\u5355\u5730\u6765\u8bf4\uff0c\u6570\u636e\u4ece\u4e00\u7aef\u6d41\u5165\uff0c\u4ece\u53e6\u4e00\u7aef\u6d41\u51fa\uff0c\u770b\u4e0a\u53bb\u597d\u50cf\u4e00\u4e2a\u94fe\u8868\uff0c\u4e0d\u77e5\u9053\u4e3a\u4ec0\u4e48\u8981\u53d6\u8fd9\u4e48\u4e2a\u5c34\u5c2c\u7684\u540d\u5b57\u3002\u3002<\/p>\n<p>\u83ca\u82b1\u94fe\u7684\u82f1\u6587\u540d\u5b57\u53eb\u505a: Daisy-chain, \u5b83\u7684\u4e00\u4e2a\u5e94\u7528\u5c31\u662f\u505a\u8fc7\u6ee4\u5668\uff0c\u6bd4\u5982\u6211\u4eec\u6765\u7b5b\u4e0b100\u4ee5\u5185\u7684\u7d20\u6570(\u4f60\u9700\u8981\u5148\u77e5\u9053\u4ec0\u4e48\u662f\u7b5b\u6cd5)<\/p>\n<p>\u7a0b\u5e8f\u6709\u8be6\u7ec6\u7684\u6ce8\u91ca\uff0c\u4e0d\u518d\u8bf4\u660e\u4e86\u3002<\/p>\n<pre>\/*\r\n\u00a0*\u00a0 \u5229\u7528\u4fe1\u9053\u83ca\u82b1\u94fe\u7b5b\u6cd5\u6c42\u67d0\u4e00\u4e2a\u6574\u6570\u8303\u56f4\u7684\u7d20\u6570\r\n\u00a0*\u00a0 \u7b5b\u6cd5\u6c42\u7d20\u6570\u7684\u57fa\u672c\u601d\u60f3\u662f\uff1a\u628a\u4ece1\u5f00\u59cb\u7684\u3001\u67d0\u4e00\u8303\u56f4\u5185\u7684\u6b63\u6574\u6570\u4ece\u5c0f\u5230\u5927\u987a\u5e8f\u6392\u5217\uff0c\r\n\u00a0*\u00a0 1\u4e0d\u662f\u7d20\u6570\uff0c\u9996\u5148\u628a\u5b83\u7b5b\u6389\u3002\u5269\u4e0b\u7684\u6570\u4e2d\u9009\u62e9\u6700\u5c0f\u7684\u6570\u662f\u7d20\u6570\uff0c\u7136\u540e\u53bb\u6389\u5b83\u7684\u500d\u6570\u3002\r\n\u00a0*\u00a0 \u4f9d\u6b21\u7c7b\u63a8\uff0c\u76f4\u5230\u7b5b\u5b50\u4e3a\u7a7a\u65f6\u7ed3\u675f\r\n\u00a0*\/\r\npackage main\r\nimport \"fmt\"\r\n\r\nfunc xrange() chan int{ \/\/ \u4ece2\u5f00\u59cb\u81ea\u589e\u7684\u6574\u6570\u751f\u6210\u5668\r\n\u00a0\u00a0\u00a0 var ch chan int = make(chan int)\r\n\u00a0\u00a0\u00a0 go func() { \/\/ \u5f00\u51fa\u4e00\u4e2agoroutine\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 for i := 2; ; i++ {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 ch &lt;- i\u00a0 \/\/ \u76f4\u5230\u4fe1\u9053\u7d22\u8981\u6570\u636e\uff0c\u624d\u628ai\u6dfb\u52a0\u8fdb\u4fe1\u9053\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0 }()\r\n\u00a0\u00a0\u00a0 return ch\r\n}\r\n\r\nfunc filter(in chan int, number int) chan int {\r\n\u00a0\u00a0\u00a0 \/\/ \u8f93\u5165\u4e00\u4e2a\u6574\u6570\u961f\u5217\uff0c\u7b5b\u51fa\u662fnumber\u500d\u6570\u7684, \u4e0d\u662fnumber\u7684\u500d\u6570\u7684\u653e\u5165\u8f93\u51fa\u961f\u5217\r\n\u00a0\u00a0\u00a0 \/\/ in:\u00a0 \u8f93\u5165\u961f\u5217\r\n\u00a0\u00a0\u00a0 out := make(chan int)\r\n\u00a0\u00a0\u00a0 go func() {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 for {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 i := &lt;- in \/\/ \u4ece\u8f93\u5165\u4e2d\u53d6\u4e00\u4e2a\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 if i % number != 0 {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 out &lt;- i \/\/ \u653e\u5165\u8f93\u51fa\u4fe1\u9053\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0 }()\r\n\u00a0\u00a0\u00a0 return out\r\n}\r\n\r\nfunc main() {\r\n\u00a0\u00a0\u00a0 const max = 100 \/\/ \u627e\u51fa100\u4ee5\u5185\u7684\u6240\u6709\u7d20\u6570\r\n\u00a0\u00a0\u00a0 nums := xrange() \/\/ \u521d\u59cb\u5316\u4e00\u4e2a\u6574\u6570\u751f\u6210\u5668\r\n\u00a0\u00a0\u00a0 number := &lt;-nums\u00a0 \/\/ \u4ece\u751f\u6210\u5668\u4e2d\u6293\u4e00\u4e2a\u6574\u6570(2), \u4f5c\u4e3a\u521d\u59cb\u5316\u6574\u6570\r\n\u00a0\u00a0\u00a0 for number &lt;= max { \/\/ number\u4f5c\u4e3a\u7b5b\u5b50\uff0c\u5f53\u7b5b\u5b50\u8d85\u8fc7max\u7684\u65f6\u5019\u7ed3\u675f\u7b5b\u9009\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 fmt.Println(number) \/\/ \u6253\u5370\u7d20\u6570, \u7b5b\u5b50\u5373\u4e00\u4e2a\u7d20\u6570\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 nums = filter(nums, number) \/\/\u7b5b\u6389number\u7684\u500d\u6570\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 number = &lt;- nums\u00a0 \/\/ \u66f4\u65b0\u7b5b\u5b50\r\n\u00a0\u00a0\u00a0 }\r\n}<\/pre>\n<ul>\n<li>\n<h2><strong>\u968f\u673a\u6570\u751f\u6210\u5668<\/strong><\/h2>\n<\/li>\n<\/ul>\n<p>\u4fe1\u9053\u53ef\u4ee5\u505a\u751f\u6210\u5668\u4f7f\u7528\uff0c\u4f5c\u4e3a\u4e00\u4e2a\u7279\u6b8a\u7684\u4f8b\u5b50\uff0c\u5b83\u8fd8\u53ef\u4ee5\u7528\u4f5c\u968f\u673a\u6570\u751f\u6210\u5668\u3002\u5982\u4e0b\u662f\u4e00\u4e2a\u968f\u673a01\u751f\u6210\u5668:<\/p>\n<pre>func rand01() chan int {\r\n\u00a0\u00a0\u00a0 ch := make(chan int)\r\n\u00a0\u00a0\u00a0 go func () {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 for {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 select { \/\/select\u4f1a\u5c1d\u8bd5\u6267\u884c\u5404\u4e2acase, \u5982\u679c\u90fd\u53ef\u4ee5\u6267\u884c\uff0c\u90a3\u4e48\u968f\u673a\u9009\u4e00\u4e2a\u6267\u884c\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 case ch &lt;- 0:\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 case ch &lt;- 1:\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0 }()\r\n\u00a0\u00a0\u00a0 return ch\r\n}\r\n\r\nfunc main() {\r\n\u00a0\u00a0\u00a0 generator := rand01() \/\/\u521d\u59cb\u5316\u4e00\u4e2a01\u968f\u673a\u751f\u6210\u5668\r\n\u00a0\u00a0\u00a0 \/\/\u6d4b\u8bd5\uff0c\u6253\u537010\u4e2a\u968f\u673a01\r\n\u00a0\u00a0\u00a0 for i := 0; i &lt; 10; i++ {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 fmt.Println(&lt;-generator)\r\n\u00a0\u00a0\u00a0 }\r\n}<\/pre>\n<ul>\n<li>\n<h2><strong>\u5b9a\u65f6\u5668<\/strong><\/h2>\n<\/li>\n<\/ul>\n<p>\u6211\u4eec\u521a\u624d\u5176\u5b9e\u5df2\u7ecf\u63a5\u89e6\u4e86\u4fe1\u9053\u4f5c\u4e3a\u5b9a\u65f6\u5668, time\u5305\u91cc\u7684After\u4f1a\u5236\u4f5c\u4e00\u4e2a\u5b9a\u65f6\u5668\u3002\u770b\u770b\u6211\u4eec\u7684\u5b9a\u65f6\u5668\u5427\uff01<\/p>\n<pre>\/*\r\n\u00a0* \u5229\u7528\u4fe1\u9053\u505a\u5b9a\u65f6\u5668\r\n\u00a0*\/\r\npackage main\r\nimport (\r\n\u00a0\u00a0\u00a0 \"fmt\"\r\n\u00a0\u00a0\u00a0 \"time\"\r\n)\r\nfunc timer(duration time.Duration) chan bool {\r\n\u00a0\u00a0\u00a0 ch := make(chan bool)\r\n\u00a0\u00a0\u00a0 go func() {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 time.Sleep(duration)\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 ch &lt;- true \/\/ \u5230\u65f6\u95f4\u5566\uff01\r\n\u00a0\u00a0\u00a0 }()\r\n\u00a0\u00a0\u00a0 return ch\r\n}\r\nfunc main() {\r\n\u00a0\u00a0\u00a0 timeout := timer(time.Second) \/\/ \u5b9a\u65f61s\r\n\u00a0\u00a0\u00a0 for {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 select {\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 case &lt;- timeout:\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 fmt.Println(\"already 1s!\") \/\/ \u5230\u65f6\u95f4\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 return\u00a0 \/\/\u7ed3\u675f\u7a0b\u5e8f\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 }\r\n\u00a0\u00a0\u00a0 }\r\n}<\/pre>\n","protected":false},"excerpt":{"rendered":"<p>Go\u8bed\u8a00\u5e76\u53d1\u7684\u8bbe\u8ba1\u6a21\u5f0f\u548c\u5e94\u7528\u573a\u666f \u4ee5\u4e0b\u8bbe\u8ba1\u6a21\u5f0f\u548c\u5e94\u7528\u573a\u666f\u6765\u81eaGoogle IO\u4e0a\u7684\u5173\u4e8eGoroutine\u7684PPT:https:\/\/talks.golang.org\/2012\/concurrency.slide \u672c\u6587\u7684\u793a\u4f8b\u4ee3\u7801\u5728:\u00a0https:\/\/github.com\/hit9\/Go-patterns-with-channel \u751f\u6210\u5668 \u5728Python\u4e2d\u6211\u4eec\u53ef\u4ee5\u4f7f\u7528yield\u5173\u952e\u5b57\u6765\u8ba9\u4e00\u4e2a\u51fd\u6570\u6210\u4e3a\u751f\u6210\u5668\uff0c\u5728Go\u4e2d\u6211\u4eec\u53ef\u4ee5\u4f7f\u7528\u4fe1\u9053\u6765\u5236\u9020\u751f\u6210\u5668(\u4e00\u79cdlazy load\u7c7b\u4f3c\u7684\u4e1c\u897f)\u3002\u5f53\u7136\u6211\u4eec\u7684\u4fe1\u9053\u5e76\u4e0d\u662f\u7b80\u5355\u7684\u505a\u963b\u585e\u4e3b\u7ebf\u7684\u529f\u80fd\u6765\u4f7f\u7528\u7684\u54e6\u3002 \u4e0b\u9762\u662f\u4e00\u4e2a\u5236\u4f5c\u81ea\u589e\u6574\u6570\u751f\u6210\u5668\u7684\u4f8b\u5b50\uff0c\u76f4\u5230\u4e3b\u7ebf\u5411\u4fe1\u9053\u7d22\u8981\u6570\u636e\uff0c\u6211\u4eec\u624d\u6dfb\u52a0\u6570\u636e\u5230\u4fe1\u9053 func xrange() chan int{ \/\/ xrange\u7528\u6765\u751f\u6210\u81ea\u589e\u7684\u6574\u6570 \u00a0\u00a0\u00a0 var ch chan int = make(chan int) \u00a0\u00a0\u00a0 go func() { \/\/ \u5f00\u51fa\u4e00\u4e2agoroutine \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 for i := 0; ; i++ { \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 ch &lt;- i\u00a0 \/\/ \u76f4\u5230\u4fe1\u9053\u7d22\u8981\u6570\u636e\uff0c\u624d\u628ai\u6dfb\u52a0\u8fdb\u4fe1\u9053 \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 } \u00a0\u00a0\u00a0 }() \u00a0\u00a0\u00a0 return ch } func main() { \u00a0\u00a0\u00a0 generator [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[17],"tags":[],"class_list":["post-15450","post","type-post","status-publish","format-standard","hentry","category-docker"],"_links":{"self":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts\/15450","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/comments?post=15450"}],"version-history":[{"count":1,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts\/15450\/revisions"}],"predecessor-version":[{"id":15452,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts\/15450\/revisions\/15452"}],"wp:attachment":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/media?parent=15450"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/categories?post=15450"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/tags?post=15450"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}