Rumah  >  Artikel  >  pembangunan bahagian belakang  >  Pelaksanaan fungsi golang dan goroutine di perpustakaan konkurensi yang berbeza

Pelaksanaan fungsi golang dan goroutine di perpustakaan konkurensi yang berbeza

WBOY
WBOYasal
2024-04-25 13:30:021090semak imbas

Dalam bahasa Go, fungsi dan Goroutine melaksanakan pengaturcaraan serentak. Fungsi Go boleh dilaksanakan serentak melalui kata kunci go, dan Goroutines ialah utas ringan yang mencapai konkurensi dengan memperuntukkan tindanan baharu dan melaksanakan fungsi tertentu. Dalam kes praktikal, kunci mutex (pakej penyegerakan) digunakan untuk menghalang persaingan data, manakala Konteks (pakej konteks) digunakan untuk mengawal pembatalan dan tamat tempoh fungsi serentak.

Pelaksanaan fungsi golang dan goroutine di perpustakaan konkurensi yang berbeza

Pelaksanaan fungsi Go dan Goroutine dalam perpustakaan serentak yang berbeza

Go menyediakan pelbagai primitif serentak, membolehkan pembangun menulis program serentak dengan mudah. Dalam artikel ini, kami akan meneroka dua daripada perpustakaan konkurensi yang paling biasa digunakan:

  • pakej penyegerakan : Mengandungi jenis penyegerakan asas seperti mutexes (Mutex) dan pembolehubah keadaan (Cond).
  • pakej konteks: digunakan untuk mengurus tarikh akhir dan pembatalan permintaan atau operasi.

Fungsi

Fungsi Go boleh dilaksanakan secara selari, sekali gus mencapai keselarasan. Fungsi serentak boleh dibuat menggunakan sintaks berikut:

go func() {
    // 并发执行的代码
}

Goroutine

Goroutine ialah benang ringan Go yang boleh dilaksanakan serentak. Apabila Goroutine dicipta, ia akan diperuntukkan tindanan baharu dan mula melaksanakan fungsi yang diberikan. Goroutine boleh dibuat menggunakan sintaks berikut:

go func() {
    // 并发执行的代码
}()

Kes praktikal: Mutex lock

Mutex lock digunakan untuk menyelaraskan akses kepada sumber yang dikongsi dan menghalang persaingan data. Pakej penyegerakan menyediakan jenis Mutex, yang boleh kami gunakan untuk melindungi pembolehubah kongsi. Mutex 类型,我们可以使用它来保护共享变量。

import (
    "sync"
    "fmt"
)

var (
    count int
    mu sync.Mutex
)

func increment() {
    mu.Lock()
    count++
    mu.Unlock()
}

func main() {
    for i := 0; i < 1000; i++ {
        go increment()
    }
    fmt.Println(count) // 输出: 1000
}

实战案例:Context

Context 用于传递请求或操作的取消状态。context 包提供了 ContextCancelFunc

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

func main() {
    // 创建一个 Context,并在 1 秒后取消
    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    defer cancel()

    go func() {
        // 在 Context 被取消之前,不断打印
        for {
            select {
            case <-ctx.Done():
                fmt.Println("Context cancelled")
                break
            default:
                fmt.Println("Still running...")
                time.Sleep(100 * time.Millisecond)
            }
        }
    }()

    // 等待 Goroutine 完成或 Context 被取消
    <-ctx.Done()
}

Kes praktikal: Konteks

🎜🎜Konteks digunakan untuk lulus status pembatalan permintaan atau operasi. Pakej konteks menyediakan jenis Context dan CancelFunc, yang boleh kami gunakan untuk mengawal fungsi serentak. 🎜rrreee🎜Dalam pustaka concurrency yang berbeza, fungsi dan Goroutines mungkin dilaksanakan secara berbeza sedikit, tetapi konsep terasnya tetap sama. Jenis penyegerakan digunakan untuk menyelaraskan akses kepada sumber yang dikongsi, manakala Konteks digunakan untuk mengurus pembatalan dan tamat tempoh fungsi serentak. 🎜

Atas ialah kandungan terperinci Pelaksanaan fungsi golang dan goroutine di perpustakaan konkurensi yang berbeza. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan:
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn