zoukankan      html  css  js  c++  java
  • [Go] golang原子函数实现goroutine同步

    启动了两个goroutine,并完成一些工作。在各自循环的每次迭代之后,在goroutine 会使用LoadInt64 来检查shutdown 变量的值。这个函数会安全地返回
    shutdown 变量的一个副本。如果这个副本的值为1,goroutine 就会跳出循环并终止。

    package main
    
    import (
    	"fmt"
    	"sync"
    	"sync/atomic"
    	"time"
    )
    
    var (
    	//通知正在执行的goroutine停止工作的标志
    	shutdown int64
    	//计数信号量
    	wg sync.WaitGroup
    )
    
    func main() {
    	//计数加2,等待两个goroutine
    	wg.Add(2)
    	//创建两个goroutine
    	go doWork("A")
    	go doWork("B")
    	//主groutine睡眠1秒
    	time.Sleep(1 * time.Second)
    	fmt.Println("主:立刻关闭")
    	//安全的赋值全局变量
    	atomic.StoreInt64(&shutdown, 1)
    	//主goroutine等待子goroutine结束
    	wg.Wait()
    }
    
    //模拟执行工作的goroutine
    //检测主goroutine设定的值shutdown来决定是否提前终止
    func doWork(name string) {
    	defer wg.Done()
    	for {
    		fmt.Printf("%s 工作 
    ", name)
    		//子goroutine睡眠250毫秒
    		time.Sleep(250 * time.Millisecond)
    		//子goroutine读取全局变量
    		if atomic.LoadInt64(&shutdown) == 1 {
    			//停止
    			fmt.Printf("关闭 %s 
    ", name)
    			break
    		}
    	}
    }
    

      

  • 相关阅读:
    7.10.8107.79 小心80180048
    Sliverlight MD5
    WP 数据绑定Visibility
    WP7 剪贴板 Clipboard
    [10年之后我是谁]读书笔记
    linux面试题
    [你的灯亮着吗]读书笔记
    Linux命令行简明教程
    <Ruby入门教程>读书笔记
    [职场谎言系列]读书笔记
  • 原文地址:https://www.cnblogs.com/taoshihan/p/10385900.html
Copyright © 2011-2022 走看看