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

baiyuxiong · · 1629 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

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

sql = "select * from ....";

result = db.query(sql)

for(item in result)

{

.....

}

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


db的封装:

package main

 

var database *db

 

type db struct {

req chan string

res chan interface{}

}

 

func init() {

database = NewDB()

go database.Run()

}

 

//处理查询请求,请req channel中的SQL取到,执行查询后结果放在res channel中

func (d *db) Run() {

var s string

 

for {

s = <-d.req

d.res <- d.query(s)

}

}

 

func (d *db) query(sql string) interface{}{

//...

}

func NewDB() *db {

out := new(db)

out.req = make(chan string)

out.res = make(chan bool)

return out

}

 

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

sql := "select * from ...";

if database.req <- sql; res<-database.res {

//use res

}

 

这么做的好处:

1、实现了同步获取结果,和直接一个线程里调用方法效果相似。

2、调用和被调用在独立的协程里

3、查询列表是一个先进先出的队列


有疑问加站长微信联系(非本文作者)

本文来自:博客园

感谢作者:baiyuxiong

查看原文:利用channel在goroutins之间控制同步和传递数据

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:1006366459

1629 次点击  
加入收藏 微博
1 回复  |  直到 2000-01-01 00:00:00
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传