go笔记:go语言中使用协程异步并行 在go中，有了协程和chan，就能轻松而优雅的实现很多模式。 而引入future的思想可以解放思维。 ``` package utils import ( "sync" "time" ) /* Future 是一个未来的任务的抽象。和python里的那个有点类似。 在异步任务中SetResult，在GetResult的时候会等待result生成，或者超时。 使用姿势： tasks := make([]*utils.Future, 0) for i := 0; i < 10; i++ { future := utils.NewFuture() tasks = append(tasks, future) go func(result int) { time.Sleep(time.Second * time.Duration(rand.Int63n(10))) future.SetResult(result) }(i) } for _, item := range tasks { ret, ok := item.GetResult().(int) if ok { fmt.Println(ret) } else { fmt.Println("failed") } } */ type Future struct { isfinished bool result interface{} resultchan chan interface{} l sync.Mutex } func (f *Future) GetResult() interface{} { f.l.Lock() defer f.l.Unlock() if f.isfinished { return f.result } select { // timeout case <-time.Tick(time.Second * 6): f.isfinished = true f.result = nil return nil case f.result = <-f.resultchan: f.isfinished = true return f.result } } func (f *Future) SetResult(result interface{}) { if f.isfinished == true { return } f.resultchan <- result close(f.resultchan) } func NewFuture() *Future { return &Future{ isfinished: false, result: nil, resultchan: make(chan interface{}, 1), } } ``` 来自 大脸猫 写于 2017-08-26 20:33 -- 更新于2020-10-19 13:06 -- 0 条评论