-
Notifications
You must be signed in to change notification settings - Fork 0
/
use_mutex.go
67 lines (55 loc) · 1.22 KB
/
use_mutex.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
package syncs
import (
"sync"
"github.com/devlights/gomy/output"
)
// UseMutex -- sync.Mutex のサンプルです。
//
// - sync/atomic.AddXXX のサンプルは atomic_add.go を参照。
// - 同期なしのサンプルは no_sync.go を参照。
// - チャネルを使ったサンプルは use_channel.go を参照。
//
// # REFERENCES
// - https://pkg.go.dev/sync@go1.17.8
// - https://pkg.go.dev/sync/atomic@go1.17.8
// - https://levelup.gitconnected.com/go-a-benchmark-to-compare-synchronization-techniques-ed73e118ec35
func UseMutex() error {
var (
wg sync.WaitGroup
m sync.Mutex
x int32 = 0
fn = func(minus bool) {
defer wg.Done()
for i := 0; i < 50000; i++ {
m.Lock()
if minus {
x--
} else {
x++
}
m.Unlock()
}
}
)
for i := 0; i < 5; i++ {
wg.Add(2)
go fn(true)
go fn(false)
wg.Wait()
output.Stdoutl("[x]", x)
}
return nil
/*
$ task
task: [build] go build .
task: [run] ./try-golang -onetime
ENTER EXAMPLE NAME: syncs_use_mutex
[Name] "syncs_use_mutex"
[x] 0
[x] 0
[x] 0
[x] 0
[x] 0
[Elapsed] 4.79704ms
*/
}