Go sync包常见方法使用

1.线程安全的map

package main

import (
        "fmt"
        "sync"
)

type SafeMap struct {
        m map[int]int
        sync.Mutex
}

func newSafeMap() *SafeMap {
        newMap := new(SafeMap)
        newMap.m = make(map[int]int)
        return newMap
}

func (s *SafeMap) Put(key int, value int) {
        s.Lock()
        s.m[key] = value
        s.Unlock()
}

func (s *SafeMap) Get(key int) (value int) {
        s.Lock()
        value = s.m[key]
        s.Unlock()
        return
}
func main() {
        var m sync.Map
        // var mn = make(map[int]int)
        ms := newSafeMap()
        go func(ms *SafeMap) {
                // mn[1] = 1
                m.LoadOrStore(1, 3)
                ms.Put(1, 5)
        }(ms)

        go func(ms *SafeMap) {
                // mn[1] = 2
                m.LoadOrStore(1, 4)
                ms.Put(1, 6)
        }(ms)

        go func(ms *SafeMap) {
                fmt.Println()
                fmt.Println("goroutine 1 slock: ", ms.Get(1)) //goroutine 1 slock:  0
                v, _ := m.Load(1)
                fmt.Println("goroutine 1: ", v) //goroutine 1:  4
        }(ms)
        go func(ms *SafeMap) {
                fmt.Println()
                fmt.Println("goroutine 2 slock: ", ms.Get(1))  //goroutine 2 slock:  0
                v, _ := m.Load(1)
                fmt.Println("goroutine 2: ", v) //goroutine 2:  4
        }(ms)
        v, _ := m.Load(1)
        fmt.Println("main goroutine: ", v) //main goroutine:  <nil>
        // fmt.Println(mn[1])
        fmt.Println("main goroutine slock: ", ms.Get(1)) //main goroutine slock:  5
}

卖票

package main

import (
    "fmt"
    "runtime"
    "time"
    "math/rand"
    "sync"
)
var total_tickets int32 = 10
var mutex = &sync.Mutex{}
func f(i int) {
    for {
        mutex.Lock()
        if total_tickets > 0 {
            time.Sleep(time.Duration(rand.Intn(5))* time.Millisecond)
            total_tickets--
            fmt.Println("id ", i, " tickets: ", total_tickets)
        } else {
            break
        }
        mutex.Unlock()
    }
}

func main() {
    runtime.GOMAXPROCS(4)
    rand.Seed(time.Now().Unix())
    for i:=0; i<5;i++ {
        go f(i)
    }
    var input string
    fmt.Scanln(&input)
    fmt.Println(total_tickets, "done")
}

package main
import (
    "fmt"
    "runtime"
    "time"
    "math/rand"
    "sync"
    "sync/atomic"
)
var total_tickets int32 = 10
var mutex = &sync.Mutex{}
func f(i int) {
    for {
        mutex.Lock()
        if total_tickets > 0 {
            time.Sleep(time.Duration(rand.Intn(5))* time.Millisecond)
            total_tickets--
            fmt.Println("id ", i, " tickets: ", total_tickets)
        } else {
            break
        }
        mutex.Unlock()
    }
}

func syncatomic() {
    var cnt uint32 = 0
    for i:=0;i<10;i++ {
        go func() {
            for i:=0;i<20;i++{
                time.Sleep(time.Millisecond)
                atomic.AddUint32(&cnt, 1)
            }
        }()
    }
    time.Sleep(time.Second)
    cntFinal := atomic.LoadUint32(&cnt)
    fmt.Println("cnt: ", cntFinal)
}
func main() {
    runtime.GOMAXPROCS(4)
    rand.Seed(time.Now().Unix())
    for i:=0; i<5;i++ {
        go f(i)
    }
    syncatomic()
    var input string
    fmt.Scanln(&input)
    fmt.Println(total_tickets, "done")
}

在一个逻辑处理器上并发运行协程

// syncdo
package main

import (
    "fmt"
    "runtime"
    "sync"
)

func main() {
    runtime.GOMAXPROCS(1)

    var wg sync.WaitGroup
    wg.Add(2)

    fmt.Println("Starting Go Routines")
    go func() {
        defer wg.Done()

        for char := 'a'; char < 'a'+26; char++ {
            fmt.Printf("%c ", char)
        }
    }()

    go func() {
        defer wg.Done()

        for number := 1; number < 27; number++ {
            fmt.Printf("%d ", number)
        }
    }()

    fmt.Println("Waiting To Finish")
    wg.Wait()

    fmt.Println("\nTerminating Program")
}

Output:

Starting Go Routines
Waiting To Finish
a b c d e f g h i j k l m n o p q r s t u v w x y z 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
Terminating Program

将第一个协程慢一拍执行

package main

import (
    "fmt"
    "runtime"
    "sync"
    "time"
)

func main() {
    runtime.GOMAXPROCS(1)

    var wg sync.WaitGroup
    wg.Add(2)

    fmt.Println("Starting Go Routines")
    go func() {
        defer wg.Done()

        time.Sleep(1 * time.Microsecond)
        for char := ‘a’; char < ‘a’+26; char++ {
            fmt.Printf("%c ", char)
        }
    }()

    go func() {
        defer wg.Done()

        for number := 1; number < 27; number++ {
            fmt.Printf("%d ", number)
        }
    }()

    fmt.Println("Waiting To Finish")
    wg.Wait()

    fmt.Println("\nTerminating Program")
}

Output:

Starting Go Routines
Waiting To Finish
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 a b c d e f g h i j k l m n o p q r s t u v w x y z 
Terminating Program

并行运行

package main

import (
    "fmt"
    "runtime"
    "sync"
)

func main() {
    runtime.GOMAXPROCS(2)

    var wg sync.WaitGroup
    wg.Add(2)

    fmt.Println("Starting Go Routines")
    go func() {
        defer wg.Done()

        for char := ‘a’; char < ‘a’+26; char++ {
            fmt.Printf("%c ", char)
        }
    }()

    go func() {
        defer wg.Done()

        for number := 1; number < 27; number++ {
            fmt.Printf("%d ", number)
        }
    }()

    fmt.Println("Waiting To Finish")
    wg.Wait()

    fmt.Println("\nTerminating Program")
}

Output:

Starting Go Routines
Waiting To Finish
1 2 a b c d e f g h i j k l m n o p q r s t u v 3 4 5 6 7 8 9 w x y z 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 
Terminating Program
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 204,189评论 6赞 478
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 85,577评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 150,857评论 0赞 337
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,703评论 1赞 276
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,705评论 5赞 366
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,620评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,995评论 3赞 396
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,656评论 0赞 258
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,898评论 1赞 298
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,639评论 2赞 321
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,720评论 1赞 330
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,395评论 4赞 319
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,982评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,953评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,195评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 44,907评论 2赞 349
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,472评论 2赞 342