Golang 实现 Futures 模式

package main
 
import (
    "fmt"
    "sync"
    "time"
)
 
// 定义Future接口
type Future interface {
    Get() interface{}
}
 
// 实现Future接口的FutureTask
type FutureTask struct {
    result interface{}
    done   chan bool
    wg     sync.WaitGroup
    action func() interface{}
}
 
// 创建一个新的FutureTask
func NewFutureTask(action func() interface{}) *FutureTask {
    return &FutureTask{
        done:   make(chan bool),
        action: action,
    }
}
 
// 运行异步任务
func (ft *FutureTask) Run() {
    ft.wg.Add(1)
    go ft.run()
}
 
func (ft *FutureTask) run() {
    defer ft.wg.Done()
    ft.result = ft.action()
    <-ft.done // 阻塞，直到调用者关闭done channel
}
 
// 获取运行结果，如果任务尚未完成，阻塞等待
func (ft *FutureTask) Get() interface{} {
    ft.wg.Wait() // 等待任务完成
    return ft.result
}
 
func main() {
    // 创建一个FutureTask并运行
    futureTask := NewFutureTask(func() interface{} {
        time.Sleep(2 * time.Second) // 模拟耗时操作
        return "任务完成"
    })
    futureTask.Run()
 
    // 执行其他任务
    fmt.Println("执行其他任务...")
    time.Sleep(1 * time.Second) // 模拟其他任务耗时
 
    // 获取FutureTask的结果
    result := futureTask.Get().(string)
    fmt.Println(result)
}

这段代码定义了一个Future接口和实现该接口的FutureTask结构体。它展示了如何创建一个FutureTask，运行一个异步任务，并在需要的时候同步获取任务结果。这是一个简化的Futures模式实现，适用于学习和教育目的。