Golang でファイルを同時に読み書きするにはどうすればよいですか?

同時ファイル読み取り: データ ブロックを同時に読み取る goroutine を作成し、パイプライン通信調整を使用します。同時ファイル書き込み: goroutine を使用してデータを書き込み、mutex を使用して書き込み操作を保護します。

Golang でファイルを同時に読み書きするにはどうすればよいですか?

ファイル I/O の同時処理は、Golang プログラムのパフォーマンスを向上させる一般的な手法です。同時アクセスを使用すると、ある操作が完了するのを待ってから別の操作を開始するのではなく、データの読み取りと書き込みを同時に行うことができます。この記事では、goroutine を使用して Golang でファイルの読み取りと書き込みを同時に行う方法を説明します。

同時読み取り

ファイルを同時に読み取るために、複数のゴルーチンを作成し、各ゴルーチンがファイルからデータ ブロックを読み取ります。これらのゴルーチンを調整するには、パイプを使用して通信します。

package main

import (
    "bufio"
    "os"
    "fmt"
    "sync"
    "time"
)

func readFile(filePath string, wg *sync.WaitGroup, ch chan<- string) {
    defer wg.Done()
    file, err := os.Open(filePath)
    if err != nil {
        fmt.Println(err)
        return
    }
    defer file.Close()

    scanner := bufio.NewScanner(file)
    for scanner.Scan() {
        ch <- scanner.Text()
    }
}

func main() {
    // 创建一个容量为 10 的管道
    ch := make(chan string, 10)

    // 等待组用于跟踪 goroutine
    var wg sync.WaitGroup

    filePath := "filename.txt"
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go readFile(filePath, &wg, ch)
    }

    // 从管道中读取数据，并停止管道以等待所有 goroutine 完成
    go func() {
        wg.Wait()
        close(ch)
    }()

    for data := range ch {
        fmt.Println(data)
    }

    // 等待管道数据完全输出
    time.Sleep(1 * time.Second)
}

同時書き込み

ファイルへの同時書き込みの場合も同様のアプローチを使用しますが、データの書き込みにはゴルーチンを使用し、書き込み操作への排他的アクセスを保証するためにミューテックスを使用します。

りー

以上がGolang でファイルを同時に読み書きするにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。