Golang如何处理并发任务的超时与重试_Golang并发任务超时重试方法详解

ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
<p>req, _ := http.NewRequest("GET", "<a href="https://www.php.cn/link/46b315dd44d174daf5617e22b3ac94ca">https://www.php.cn/link/46b315dd44d174daf5617e22b3ac94ca</a>", nil)
req = req.WithContext(ctx)</p><p>client := &http.Client{}
resp, err := client.Do(req)
if err != nil {
log.Printf("请求失败: %v", err)
return
}
defer resp.Body.Close()</p>

func doWithRetry(attempts int, sleep time.Duration, action func() error) error {
    var err error
    for i := 0; i < attempts; i++ {
        err = action()
        if err == nil {
            return nil
        }
<pre class='brush:php;toolbar:false;'>    log.Printf("第 %d 次尝试失败: %v", i+1, err)
    if i < attempts-1 {
        time.Sleep(sleep)
        sleep *= 2 // 指数退避
    }
}
return fmt.Errorf("所有重试均失败: %w", err)

err := doWithRetry(3, 1*time.Second, func() error {
    ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
    defer cancel()
<pre class='brush:php;toolbar:false;'>req, _ := http.NewRequest("GET", "https://www.php.cn/link/46b315dd44d174daf5617e22b3ac94ca", nil)
req = req.WithContext(ctx)

resp, err := client.Do(req)
if err != nil {
    return err
}
resp.Body.Close()
return nil

jitter := time.Duration(rand.Int63n(1000)) * time.Millisecond
sleep += jitter