我就废话不多说了,大家还是直接看代码吧~

func main() {
  var a chan string
  a =make(chan string)
  go sendDataTo(a)
  go timing()
  getAchan(10*time.Second,a)
}
func sendDataTo(a chan string) {
  for {
     a <- "我是a通道的数据"
    time.Sleep(1e9 *3)
  }
}
//在一定时间内接收不到a的数据则超时
func getAchan(timeout time.Duration, a chan string) {
  var after <-chan time.Time
  loop:
  after = time.After(timeout)
  for{
    fmt.Println("等待a中的数据,10秒后没有数据则超时")
    select {
    case x :=<- a:
      fmt.Println(x)
      goto loop
    case <-after:
      fmt.Println("timeout.")
      return
    }
  }
}
func timing() {
  //定时器,10秒钟执行一次
  ticker := time.NewTicker(10 * time.Second)
  for {
    time := <-ticker.C
    fmt.Println("定时器====>",time.String())
  }
}     

补充:golang的定时器NewTimer、NewTicker使用

废话不多说,直接看代码

package main 
import (
  "fmt"
  "sync"
  "time"
)
 
/**
*ticker只要定义完成,从此刻开始计时,不需要任何其他的操作,每隔固定时间都会触发。
*timer定时器,是到固定时间后会执行一次
*如果timer定时器要每隔间隔的时间执行,实现ticker的效果,使用 func (t *Timer) Reset(d Duration) bool
 */
func main() {
  var wg sync.WaitGroup
  wg.Add(2)
  //NewTimer 创建一个 Timer,它会在最少过去时间段 d 后到期,向其自身的 C 字段发送当时的时间
  timer1 := time.NewTimer(2 * time.Second)
 
  //NewTicker 返回一个新的 Ticker,该 Ticker 包含一个通道字段,并会每隔时间段 d 就向该通道发送当时的时间。它会调 
  //整时间间隔或者丢弃 tick 信息以适应反应慢的接收者。如果d <= 0会触发panic。关闭该 Ticker 可      
  //以释放相关资源。
  ticker1 := time.NewTicker(2 * time.Second)
 
  go func(t *time.Ticker) {
    defer wg.Done()
    for {
      <-t.C
      fmt.Println("get ticker1", time.Now().Format("2006-01-02 15:04:05"))
    }
  }(ticker1)
 
  go func(t *time.Timer) {
    defer wg.Done()
    for {
      <-t.C
      fmt.Println("get timer", time.Now().Format("2006-01-02 15:04:05"))
      //Reset 使 t 重新开始计时,(本方法返回后再)等待时间段 d 过去后到期。如果调用时t   
      //还在等待中会返回真;如果 t已经到期或者被停止了会返回假。
      t.Reset(2 * time.Second)
    }
  }(timer1) 
  wg.Wait()
}

运行结果:

get ticker1 2018-09-07 22:44:29

get timer 2018-09-07 22:44:29

...

额外说明:

time.NewTicker定时触发执行任务,当下一次执行到来而当前任务还没有执行结束时,会等待当前任务执行完毕后再执行下一次任务。查阅go官网的文档和经过代码验证。

time.NewTimer和Reset()函数实现定时触发,Reset()函数可能失败,经测试。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持。如有错误或未考虑完全的地方,望不吝赐教。

标签:
golang,定时器超时

免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
狼山资源网 Copyright www.pvsay.com

评论“golang定时器和超时的使用详解”

暂无“golang定时器和超时的使用详解”评论...

《魔兽世界》大逃杀!60人新游玩模式《强袭风暴》3月21日上线

暴雪近日发布了《魔兽世界》10.2.6 更新内容,新游玩模式《强袭风暴》即将于3月21 日在亚服上线,届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。

艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕,并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时,他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中,玩家将会进入一个全新的海盗主题大逃杀式限时活动,其中包含极高的风险和史诗级的奖励。

《强袭风暴》不是普通的战场,作为一个独立于主游戏之外的活动,玩家可以用大逃杀的风格来体验《魔兽世界》,不分职业、不分装备(除了你在赛局中捡到的),光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式,玩家在加入海盗主题的预赛大厅区域前,可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹,《巨龙崛起》和《魔兽世界:巫妖王之怒 经典版》的玩家都可以获得奖励。