Mengapakah penambahan pada kepingan dalam benang Go tidak selamat?

Mengapa Menambahkan pada Slices Boleh Menjadi Benang-Tidak Selamat

Apabila berbilang goroutine cuba menambahkan data pada kepingan secara serentak, keadaan perlumbaan data boleh berlaku. Ini kerana kepingan dalam Go tidak selamat untuk benang, bermakna berbilang goroutin boleh mengakses dan mengubah suai pengepala kepingan yang sama secara serentak, yang berpotensi menyebabkan kerosakan data.

Ilustrasi Perlumbaan Data

Pertimbangkan kod berikut:

destSlice := make([]myClass, 0)

var wg sync.WaitGroup
for _, myObject := range sourceSlice {
    wg.Add(1)
    go func(closureMyObject myClass) {
        defer wg.Done()
        var tmpObj myClass
        tmpObj.AttributeName = closureMyObject.AttributeName
        destSlice = append(destSlice, tmpObj)
    }(myObject)
}
wg.Wait()

Dalam kod ini, berbilang goroutin secara serentak ditambah pada kepingan destSlice. Ini boleh menyebabkan data hilang atau kosong dalam kepingan yang terhasil, kerana goroutine boleh menyelang operasinya dan menimpa perubahan satu sama lain.

Mengesahkan Perlumbaan Data dengan Pilihan "-race"

Menjalankan kod dengan pilihan "-race" akan menjana amaran untuk setiap perlumbaan data yang dikesan. Output berikut menggambarkan keadaan perlumbaan data dalam kod yang disediakan:

==================
WARNING: DATA RACE
Read at 0x00c420074000 by goroutine 6:
  main.main.func1()
      /home/icza/gows/src/play/play.go:20 +0x69

Previous write at 0x00c420074000 by goroutine 5:
  main.main.func1()
      /home/icza/gows/src/play/play.go:20 +0x106

Goroutine 6 (running) created at:
  main.main()
      /home/icza/gows/src/play/play.go:21 +0x1cb

Goroutine 5 (running) created at:
  main.main()
      /home/icza/gows/src/play/play.go:21 +0x1cb
==================

Penyelesaian: Menggunakan Mutex untuk Penyegerakan

Untuk memastikan sambungan selamat benang dilampirkan, anda boleh menggunakan mutex untuk melindungi pengepala hirisan destSlice. Kod yang diubah suai berikut menunjukkan perkara ini:

var (
    mu        = &sync.Mutex{}
    destSlice = make([]myClass, 0)
)

var wg sync.WaitGroup
for _, myObject := range sourceSlice {
    wg.Add(1)
    go func(closureMyObject myClass) {
        defer wg.Done()
        var tmpObj myClass
        tmpObj.AttributeName = closureMyObject.AttributeName
        mu.Lock()
        destSlice = append(destSlice, tmpObj)
        mu.Unlock()
    }(myObject)
}
wg.Wait()

Dengan memperoleh mutex sebelum setiap operasi tambahan, anda menghalang berbilang goroutin daripada mengubah suai pengepala kepingan secara serentak, memastikan integriti data dan menghapuskan keadaan perlumbaan data.

Atas ialah kandungan terperinci Mengapakah penambahan pada kepingan dalam benang Go tidak selamat?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!