Comment résoudre le problème de la limite de temps des tâches simultanées en langage Go ?-Golang-php.cn

Comment résoudre le problème de la limite de temps des tâches simultanées en langage Go ?

WBOY

Libérer： 2023-10-08 08:33:25

original

493 Les gens l'ont consulté

Comment résoudre le problème de la limite de temps des tâches simultanées en langage Go ?

Comment résoudre le problème de limite de temps des tâches simultanées en langage Go ?

En développement, nous rencontrons souvent des tâches qui doivent être accomplies dans un temps limité, comme l'expiration du délai de demande, l'expiration de la tâche, etc. En langage Go, nous pouvons utiliser certaines méthodes pour résoudre ces problèmes. Cet article présentera plusieurs solutions courantes avec des exemples de code.

Utilisation du package de contexte

Le package de contexte est fourni dans la bibliothèque standard du langage Go pour traiter les informations contextuelles des tâches. Il peut transmettre des informations de contexte de tâche entre les coroutines et fournir des fonctions de contrôle de délai d'attente. Voici un exemple de code qui utilise le package de contexte pour résoudre la limite de temps des tâches simultanées :

package main

import (
    "context"
    "fmt"
    "time"
)

func main() {
    timeout := 3 * time.Second
    ctx, cancel := context.WithTimeout(context.Background(), timeout)
    defer cancel()

    ch := make(chan string)
    go doTask(ctx, ch)

    select {
    case res := <-ch:
        fmt.Println(res)
    case <-ctx.Done():
        fmt.Println("任务超时")
    }
}

func doTask(ctx context.Context, ch chan<- string) {
    time.Sleep(5 * time.Second)
    ch <- "任务完成"
}

Copier après la connexion

Dans le code ci-dessus, nous utilisons la fonction context.WithTimeout pour créer un contexte ctx avec un délai d'attente. fonction et définir la tâche. Le temps d'exécution maximum est de 3 secondes. Dans la fonction main, nous utilisons la fonction doTask pour démarrer une tâche d'exécution de coroutine et renvoyer le résultat de l'exécution de la tâche via le canal ch. À l'aide de l'instruction select, nous pouvons surveiller simultanément les résultats de l'exécution de la tâche et l'état du délai d'attente, afin de quitter à temps lorsque la tâche expire et d'éviter que l'exécution de la tâche ne prenne trop de temps. context.WithTimeout函数创建了一个带有超时功能的上下文ctx，设定了任务的最长执行时间为3秒。在main函数中，我们使用doTask函数开启了一个协程执行任务，并通过ch通道返回任务执行结果。使用select语句，我们可以同时监视任务执行结果和超时状态，从而在任务超时时及时退出，避免任务执行时间过长。

使用time包

除了context包，我们还可以使用time包提供的定时器功能来解决并发任务限时问题。下面是一个使用time包解决并发任务限时的示例代码：

package main

import (
    "fmt"
    "time"
)

func main() {
    timeout := 3 * time.Second
    ch := make(chan string)
    done := make(chan bool)

    go doTask(ch, done)

    select {
    case res := <-ch:
        fmt.Println(res)
    case <-time.After(timeout):
        fmt.Println("任务超时")
    }

    <-done
}

func doTask(ch chan<- string, done chan<- bool) {
    time.Sleep(5 * time.Second)
    ch <- "任务完成"
    done <- true
}

Copier après la connexion

在上述代码中，我们通过time.After函数创建了一个定时器，设定了任务的最长执行时间为3秒。使用select

time.After

select

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!