利用channel在goroutins之间控制同步和传递数据

￡神魔★判官ぃ 2022-09-26 02:19 138阅读 0赞

# [利用channel在goroutins之间控制同步和传递数据][channel_goroutins] #

[发表回复][Link 1]

在java等代码中，我们查询数据库的操作：

<table> 
 <tbody> 
 <tr> 
 <td> 
 <div>
 1 
 2 
 3 
 4 
 5 
 6 
 
 </div> </td> 
 <td> 
 <div>
 sql 
 = 
 "select * from ...." 
 ; 
 result 
 = db. 
 query 
 (sql 
 ) 
 
 for 
 (item in result 
 ) 
 
 { 
 ..... 
 
 } 
 </div> </td> 
 </tr> 
 </tbody> 
</table>

但是在go语言中，这么做就有些土了，我们可以利用channel天生的队列和线程同步的特性来实现。这也是go和其它语言很明显的思维区别。

db的封装：

<table> 
 <tbody> 
 <tr> 
 <td> 
 <div>
 1 
 2 
 3 
 4 
 5 
 6 
 7 
 8 
 9 
 10 
 11 
 12 
 13 
 14 
 15 
 16 
 17 
 18 
 19 
 20 
 21 
 22 
 23 
 24 
 25 
 26 
 27 
 28 
 29 
 30 
 31 
 32 
 33 
 
 </div> </td> 
 <td> 
 <div>
 package main 
 
 var database 
 *db 
 
 type db 
 struct 
 { 
 &nbsp; &nbsp; req &nbsp; chan string 
 &nbsp; &nbsp; res &nbsp; chan interface 
 { 
 } 
 
 } 
 
 func init 
 ( 
 ) 
 { 
 &nbsp; &nbsp; database 
 = NewDB 
 ( 
 ) 
 &nbsp; &nbsp; go database. 
 Run 
 ( 
 ) 
 
 } 
 
 
 //处理查询请求，请req channel中的SQL取到，执行查询后结果放在res channel中 
 func 
 (d 
 *db 
 ) Run 
 ( 
 ) 
 { 
 &nbsp; &nbsp; var s string 
 
 &nbsp; &nbsp; 
 for 
 { 
 &nbsp; &nbsp; &nbsp; &nbsp; s 
 = 
 &lt;-d. 
 req 
 &nbsp; &nbsp; &nbsp; &nbsp; d. 
 res 
 &lt;- d. 
 query 
 (s 
 ) 
 &nbsp; &nbsp; 
 } 
 
 } 
 
 func 
 (d 
 *db 
 ) query 
 (sql string 
 ) interface 
 { 
 } 
 { 
 &nbsp; &nbsp; 
 //... 
 
 } 
 func NewDB 
 ( 
 ) 
 *db 
 { 
 &nbsp; &nbsp; out 
 := new 
 (db 
 ) 
 &nbsp; &nbsp; out. 
 req 
 = make 
 (chan string 
 ) 
 &nbsp; &nbsp; out. 
 res 
 = make 
 (chan bool 
 ) 
 &nbsp; &nbsp; 
 return out 
 
 } 
 </div> </td> 
 </tr> 
 </tbody> 
</table>

调用时，将sql放入请求队列，并阻塞等待响应结果

<table> 
 <tbody> 
 <tr> 
 <td> 
 <div>
 1 
 2 
 3 
 4 
 
 </div> </td> 
 <td> 
 <div>
 sql 
 := 
 "select * from ..." 
 ; 
 
 if database. 
 req 
 &lt;- sql 
 ; res 
 &lt;-database. 
 res 
 { 
 &nbsp; &nbsp; 
 //use res 
 
 } 
 </div> </td> 
 </tr> 
 </tbody> 
</table>

这么做的好处：  
1、实现了同步获取结果，和直接一个线程里调用方法效果相似。  
2、调用和被调用在独立的协程里  
3、查询列表是一个先进先出的队列

[channel_goroutins]: http://www.baiyuxiong.com/?p=1095
[Link 1]: http://www.baiyuxiong.com/?p=1095#respond