GO言語で共有されている複数のゴロウチンのデータベース接続を適切に閉じるにはどうすればよいですか？

Go Multi-Goroutine共有データベース接続のエレガントなクローズ

Go Compurrentプログラミングでは、複数のGoroutine共有データベース接続が一般的なシナリオです。不適切な接続シャットダウンにより、データの損失やプログラムのクラッシュが発生する可能性があります。この記事では、複数のゴロウチン共有のデータベース接続を安全に閉じる方法について説明します。

問題分析：

メインゴルウチンでdefer db.Close()直接使用することは、すべての子供ゴルチンがデータベース操作を完了したことを保証することはできません。これにより、接続が事前に閉じてエラーが発生する可能性があります。各子供のゴルチンでdefer db.Close()を使用すると、接続が複数回閉じられ、同じエラーが発生します。

解決：

カウンターとsync.WaitGroup使用して、ゴロウチンの実行とデータベース接続の閉鎖を調整することをお勧めします。

サンプルコード：

パッケージメイン

輸入 （
    「FMT」
    「同期」
    "時間"

    「データベース/SQL」
    _ "github.com/go-sql-driver/mysql" //データベースドライバーに置き換えます）

タイプdbconn struct {
    conn *sql.db
    wg *sync.waitgroup
}

func opendb（）（*dbconn、error）{
    db、err：= sql.open（ "mysql"、 "user：password@tcp（127.0.0.1:3306）/database"）// err！= nil {の場合、データベース接続文字列に置換
        nil、errを返します
    }
    return＆dbconn {conn：db、wg：＆sync.waitgroup {}}、nil
}

func（dc *dbconn）close（）error {
    dc.wg.wait（）//すべてのゴルチンがreturn dc.conn.close（）を完了するのを待ちます
}

func querydb（dc *dbconn、i int）{
    dc.wg.done（）を延期する
    dc.wg.add（1）//カウンターが追加されます1
    // ...データベース操作...
    time.sleep（time.second）//データベース操作のシミュレーション時間消費fmt.printf（ "goroutine％d finent \ n"、i）
}

func main（）{
    dc、err：= opendb（）
    err！= nil {
        fmt.println（ "エラーオープニングデータベース："、err）
        戻る
    }
    dc.close（）// dc.close（）// i：= 0の最後に接続を閉じるようにしてください。 I <p><strong>コード説明：</strong></p><ol>
<li> <code>dbConn</code>構造には、Goroutinesの実行を管理するためのデータベース接続と<code>sync.WaitGroup</code>が含まれています。</li>
<li> <code>openDb</code>関数はデータベース接続を開き、 <code>dbConn</code>インスタンスを返します。</li>
<li> <code>close</code> Methodでは<code>dc.wg.Wait()</code>を使用して、すべてのゴルチンが完了するのを待ってからデータベース接続を閉じる前に完了します。</li>
<li> <code>querydb</code>関数は<code>dc.wg.Add(1)</code>を使用してデータベース操作を実行する前にカウンターを増やし、 <code>defer dc.wg.Done()</code>を使用して操作が完了した後にカウンターを減らします。</li>
<li> <code>main</code>関数は、 <code>querydb</code>関数を実行するために複数のゴルチンを開始し、 <code>defer dc.close()</code>を使用してデータベース接続を閉じます。</li>
</ol><p>この方法により、すべてのゴルチンがデータベース操作を完了し、データベース接続を閉じることが保証され、データの損失とエラーが回避されます。サンプルコードのデータベース接続文字列とドライバーを置き換えることを忘れないでください。データベースの操作時間が予測不可能な場合、チャネルを使用したシグナリングなど、すべてのゴルチンが完了するのを待つために、より複雑なメカニズムが必要になる場合があります。</p>

以上がGO言語で共有されている複数のゴロウチンのデータベース接続を適切に閉じるにはどうすればよいですか？の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。