キャンセルとタイムアウトのためにGOでコンテキストパッケージを使用する

コンテキストを使用して、ゴロウチン全体のキャンセルと締め切りを伝播し、HTTPサーバー、バックグラウンドタスク、チェーンコールでの協力的キャンセルを可能にします。 2。Context.WithCancel（）を使用して、キャンセル可能なコンテキストを作成し、Cancel（）を呼び出して終了を信号し、常にcancel（）を延期してリークを防ぎます。 3.タイムアウトの場合、context.withtimeout（）を使用して操作期間を制限し、ctx.done（）またはctx.err（）をチェックして締め切りを処理します。 4。HTTPハンドラーでは、リクエストコンテキストをタイムアウトで拡張し、下流に渡し、バックエンド操作にクライアントリクエストのライフサイクルを尊重します。 5.ベストプラクティスには、常にCancel（）を呼び出し、コンテキストを最初のパラメーターとして通過させること、構造体のコンテキストストレージの回避、時間の経過とともにTimeOutを好む。 6. CANCEL（）を呼び出すのを忘れたり、CTX.ERR（）を無視したり、非リケストデータのコンテキストの過剰使用などの一般的な落とし穴を避けてください。適切なコンテキストの使用により、キャンセル可能な操作が明示的に管理され、リソースが効率的にリリースされる回復力のある応答性のあるGOアプリケーションが保証されます。

GOに同時アプリケーションを構築する場合、キャンセルとタイムアウトの優雅に処理することが不可欠です。 contextパッケージは、リクエストスコープされた値、キャンセル信号、およびゴルチン全体の締め切りを管理するためのクリーンで効率的な方法を提供します。 HTTPサーバー、バックグラウンドタスク、およびチェーン機能呼び出しを備えたシステムで特に役立ちます。

キャンセルとタイムアウトのためにcontextパッケージを効果的に使用する方法は次のとおりです。

1.なぜコンテキストを使用するのですか？

コンテキストがなければ、ランニングゴルウチンに停止するように指示するのは困難です。特に、I/Oでブロックされている場合、または遅い依存関係を待っている場合です。 context.Contextタイプを使用すると、コールスタックを介してキャンセルシグナルと締め切りを伝播し、協力的なキャンセルを可能にします。

一般的なユースケース：

• クライアントが切断された場合、HTTP要求をキャンセルします。
• データベースクエリのタイミング。
• サービスが停止したときにバックグラウンドワーカーを停止します。

2。コンテキストによる基本的なキャンセル

ゴルチンをキャンセルするには、 context.WithCancel()を使用してください。

パッケージメイン

輸入 （
    "コンテクスト"
    「FMT」
    "時間"
））

func main（）{
    ctx、cancel：= context.withcancel（context.background（））
    defer cancel（）//キャンセルが呼び出されるようにリソースをリリースするように呼び出されます

    go func（ctx context.context）{
        のために {
            select {
            ケース<-ctx.done（）：
                fmt.println（ "労働者キャンセル："、ctx.err（））
                戻る
            デフォルト：
                fmt.println（ "working ..."）
                time.sleep（500 * time.millisecond）
            }
        }
    }（ctx）

    //作業を2秒間シミュレートします
    time.sleep（2 * time.second）
    cancel（）//信号キャンセル

    time.sleep（1 * time.second）//クリーンアップの仕上げをします
}

キーポイント：

• context.WithCancel()派生コンテキストとcancel関数を返します。
• cancel()を呼び出すと、 Done()チャネルが閉じます。
• 早期キャンセルを期待していなくても、メモリリークを避けるために、常にcancel()に電話してください。

3.コンテキストでタイムアウトの設定

context.WithTimeout()を使用して、操作がどれだけ時間をかけるかを制限する場合は、

 ctx、cancel：= context.withtimeout（context.background（）、3*time.second）
defer cancel（）

resultchan：= make（chan string、1）
go func（）{
    //遅い操作をシミュレートします
    time.sleep（5 * time.second）
    resultchan < - 「操作完全」
}（）

select {
ケースRES：= <-Resultchan：
    fmt.println（res）
ケース<-ctx.done（）：
    fmt.println（ "操作タイミング："、ctx.err（））
}

出力：

タイミングの操作：コンテキストの締め切りが超えました

• ctx.Err() context.DeadlineExceededがタイムアウトに達したときに成功しました。
• ゴルウチンが走り続けていても、主なロジックは待機を停止します。

4. HTTPハンドラーでコンテキストを使用します

Webサーバーでは、着信要求にはすでにコンテキストがあります。タイムアウトで拡張するか、ダウンストリームサービスに渡すことができます。

 funcハンドラー（w http.responsewriter、r *http.request）{
    //リクエストコンテキストに2秒のタイムアウトを追加します
    ctx、cancel：= context.withtimeout（r.context（）、2*time.second）
    defer cancel（）

    結果：= slowdatabasecall（ctx）
    ctx.err（）== context.deadlineex cuceeded {
        http.Error（w、 "request qietimed"、http.statusgatewaytimeout）
        戻る
    }

    w.write（[] byte（ "result：" result））
}

func slowdatabasecall（ctx context.context）string {
    select {
    ケース<-time.after（3 * time.second）：
        「データ」を返す
    ケース<-ctx.done（）：
        "//を返します。またはログキャンセル
    }
}

• r.Context()は、クライアントが接続を閉じると自動的にキャンセルされます。
• タイムアウトを追加すると、バックエンドが無期限にハングしないようにします。

5。ベストプラクティス

• 常にcancel() ： defer cancel()を使用してリソースをリリースします。
• APIを介してコンテキストを伝播します： context.Contextを受け入れる機能の最初のパラメーターとしてブロックされる可能性のある関数として。
• コンテキストを構造体に保存しないでください：議論として明示的に渡します。
• context.WithTimeoutをtime.After 。
• ルートコンテキストにはcontext.Background()を使用し、 context.TODO()まだわからない場合は使用してください。

6。一般的な落とし穴

• cancel() →リークゴルチンとメモリを呼び出すのを忘れる。
• ctx.Err() →ミスキャンセル信号を無視します。
• 必要ない値に対してコンテキストを使用してください→非クエストデータの過剰使用（たとえば、config）は、読みやすさを傷つける可能性があります。

contextパッケージを使用すると、GOプログラムがより回復力が高く応答性が高くなります。ユーザーのリクエスト、マイクロサービス、またはバックグラウンドジョブを扱うかどうかにかかわらず、コンテキストは、生涯を管理し、無駄な作業を避けるための標準的な方法を提供します。

基本的に、関数をキャンセルまたはタイムアウトする必要がある場合は、コンテキストを取る必要があります。

以上がキャンセルとタイムアウトのためにGOでコンテキストパッケージを使用するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。