周期任务碰到的几点疑惑,求解

nelson · 2016-11-29 09:37:40 · 1461 次点击 · 大约8小时之前 开始浏览    置顶
这是一个创建于 2016-11-29 09:37:40 的主题,其中的信息可能已经有所发展或是发生改变。

var (
  db = sql.Open()
  ch = make(chan int, 3)
)

func main() {
  go func() {
    ticker = time.NewTicker(time.Second)
    for t := range ticker.C {
      work()
    }
  }
}

func work() {
  go query1()
  go query2()
  go query3()

  for j := 0; j < 3; j++ {
     <-ch
  }
}

func query1() {
   rows, err := db.Query()
   checkErr(err)
   defer rows.Close()
   for rows.Next() {
      //parse
   }
   ch <- 1 // 查下结果
}

碰到这样几个疑惑

  1. db是有链接池的,为什么查到本机链接数据库的端口号会隔(2~3秒换掉),是不是每个conn执行语句数有上限呢?超过就close而不是放回连接池??
  2. 执行n次后,不再继续了,发现停在rows.Next()里了(这是什么原因呢?)

最后还想问下有没有更好的实现方式,周期性执行jobA,jobA=(数据准备获取n个goroutine结果,干正事)


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

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

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