sync.Mutex का उपयोग

// Every Go file belongs to a package; main builds an executable
package main

// Import the packages this program uses
import (
	"fmt"
	"sync"
)

// Define a struct type named Counter
type Counter struct {
	mu    sync.Mutex
	value int
}

// Define the method Increment on type Counter
func (c *Counter) Increment() {
	c.mu.Lock()
	// defer runs this call when the surrounding function returns
	defer c.mu.Unlock()
	c.value++
}

// main is where the program starts running
func main() {
	// Short declaration: create c and infer the type
	c := &Counter{}
	// Declare wg with the zero value of its type
	var wg sync.WaitGroup
	for i := 0; i < 100; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			c.Increment()
		}()
	}
	wg.Wait()
	fmt.Println(c.value)
}

Login to try C/C++/Java/PHP code in the editor

// Every Go file belongs to a package; main builds an executable
package main

// Import the packages this program uses
import (
	"fmt"
	"sync"
)

// Define a struct type named SafeMap
type SafeMap struct {
	mu   sync.Mutex
	data map[string]int
}

// Define the method Set on type SafeMap
func (m *SafeMap) Set(key string, value int) {
	m.mu.Lock()
	// defer runs this call when the surrounding function returns
	defer m.mu.Unlock()
	m.data[key] = value
}

// main is where the program starts running
func main() {
	// Short declaration: create m and infer the type
	m := &SafeMap{data: make(map[string]int)}
	m.Set("a", 1)
	// Print the values followed by a newline
	fmt.Println(m.data)
}

Login to try C/C++/Java/PHP code in the editor

// Every Go file belongs to a package; main builds an executable
package main

// Import the packages this program uses
import (
	"fmt"
	"sync"
)

// main is where the program starts running
func main() {
	// Declare mu with the zero value of its type
	var mu sync.Mutex
	// Short declaration: create total and infer the type
	total := 0
	// Declare wg with the zero value of its type
	var wg sync.WaitGroup
	// Loop: repeat while the condition holds
	for i := 0; i < 50; i++ {
		wg.Add(1)
		// Start this call in a new goroutine (runs concurrently)
		go func() {
			defer wg.Done()
			mu.Lock()
			total++
			mu.Unlock()
		}()
	}
	wg.Wait()
	fmt.Println("total:", total)
}

Login to try C/C++/Java/PHP code in the editor