好湿?好紧?好多水好爽自慰,久久久噜久噜久久综合,成人做爰A片免费看黄冈,机机对机机30分钟无遮挡

主頁 > 知識庫 > 淺談golang并發操作變量安全的問題

淺談golang并發操作變量安全的問題

熱門標簽:上海極信防封電銷卡價格 地圖標注免費定制店 重慶慶云企業400電話到哪申請 不封卡外呼系統 鄭州智能語音電銷機器人價格 湛江crm外呼系統排名 宿遷便宜外呼系統代理商 寧波語音外呼系統公司 仙桃400電話辦理

我就廢話不多說了,大家還是直接看代碼吧~

package main 
import (
	"fmt"
	"time"
	"sync"
	"sync/atomic"
)
 
func main() {
	test1()
	test2()
}
 
func test1() {
	var wg sync.WaitGroup
	count := 0
	t := time.Now()
	for i := 0 ; i  50000 ; i++ {
		wg.Add(1)
		go func(wg *sync.WaitGroup,i int) {
			count++ //count不是并發安全的
			wg.Done()
		}(wg,i)
	}
 
	wg.Wait()
	fmt.Println(time.Now().Sub(t))
	fmt.Println("count====>",count) //count的值50000
	fmt.Println("exit")
} 
 
func test2() {
	var wg sync.WaitGroup
	count := int64(0)
	t := time.Now()
	for i := 0 ; i  50000 ; i++ {
		wg.Add(1)
		go func(wg *sync.WaitGroup,i int) {
			atomic.AddInt64(count,1) //原子操作
			wg.Done()
		}(wg,i)
	}
 
	wg.Wait()
	fmt.Println(time.Now().Sub(t))
	fmt.Println("count====>",count) //count的值為50000
	fmt.Println("exit")
}

執行結果:

18.0485ms
count====> 46621
exit
16.0418ms
count====> 50000
exit

補充:golang 基于共享變量的并發

并發定義:當我們沒有辦法自信地確認一個事件是在另一個事件的前面或者后面發生的話,就說明x和y這兩個事件是并發的。

并發安全:如果其所有可訪問的方法和操作都是并發安全的話,那么類型便是并發安全的。

競爭條件:程序在多個goroutine交叉執行操作時,沒有給出正確的結果。

只要有

兩個goroutine并發訪問

同一變量,且至

少其中的一個是寫操作的時候就會發生數據競爭。

數據競爭會在兩個以上的goroutine并發訪問相同的變量且至少其中一個為寫操作時發生。

第一種:不要去寫變量,變量直接提前初始化。

第二種:多個只允許一個goroutine訪問變量,用select來監聽操作(go的金句:不要通過共享變量來通信,通過通信(channel)來共享變量)。

第三種:允許過個goroutine訪問變量,但是同一時間只允許一個goroutine訪問。

現在我們來講第三種情況具體操作

golang 我們可以通過channel作為計量器,可以保證可以有多少個goroutine可以同時訪問。make(chan struct{},1),通過寫入讀取用阻塞的方式鎖定住指定的代碼塊的訪問。

var (
sema = make(chan struct{}, 1) // a binary semaphore guarding balance
balance int
)
func Deposit(amount int) {
sema - struct{}{} // acquire token
balance = balance + amount
-sema // release token
}
func Balance() int {
sema - struct{}{} // acquire token
b := balance
-sema // release token
return b
}

可以保證同一時刻只有一個goroutine來訪問。

然而我們可以用sync包中的Mutex來實現上面的功能,那就是:

互斥鎖 sync.Mutex

互斥鎖:保證共享變量不會被并發訪問。

import "sync"
var (
mu sync.Mutex // guards balance
balance int
)
func Deposit(amount int) {
mu.Lock()
balance = balance + amount
mu.Unlock()
}
func Balance() int {
mu.Lock()
b := balance
mu.Unlock()
return b
}

在Lock和Unlock之間的代碼段中的內容goroutine可以隨便讀取或者修改,這個代碼段叫做臨界區。

注意:一定要釋放鎖(Unlock),不管任何情況,可以利用defer Mutex.Unlock(),一定要注意go里沒有重入鎖,如果遇到更小原子的操作,考慮分解成不帶鎖功能的小塊函數

接下來我們將另一種鎖:讀寫鎖sync.RWMutex

很多情況我們需要保證讀的性能,而互斥鎖會短暫的阻止其他的goroutine的運行,沒法達到很好的多并發效果(多讀單寫),這時讀寫鎖就可以很好的解決這個問題。

RLock()和RUnlock()獲取和釋放一個讀取或者共享鎖。RLock只能在臨界區共享變量沒有任何寫入操作時可用。一般來說,我們不應該假設邏輯上的只讀函數/方法也不會去更新某一些變量。如果沒法確定,那么久使用互斥鎖(Mutex)

最后我們來講下內存同步的問題

var x, y int
go func() {
x = 1 // A1
fmt.Print("y:", y, " ") // A2
}()
go func() {
y = 1 // B1
fmt.Print("x:", x, " ") // B2
}()

上面的例子:A1、A2、B1、B2 執行循序卻是毫無規律

在現代計算機中可能會有一堆處理器,每一個都會有其本地緩存(local cache)。為了效率,對內存的寫入一般會在每一個處理器中緩沖,并在必要時一起flush到主存。這種情況下這些數據可能會以與當初goroutine寫入順序不同的順序被提交到主存。導致程序運行串行了,又同時串行的代碼訪問了共享變量,盡管goroutine A中一定需要觀察到x=1執行成功之后才會去讀取y,但它沒法確保自己觀察得到goroutine B中對y的寫入,所以A還可能會打印出y的一個舊版的值。

有兩種方法解決:

1.變量限定在goroutine中使用,不訪問共享變量

2.用互斥條件訪問

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。

您可能感興趣的文章:
  • Golang實現web文件共享服務的示例代碼
  • 解決golang 關于全局變量的坑
  • Golang 變量申明的三種方式
  • Golang常用環境變量說明與設置詳解
  • Golang中的變量學習小結
  • 詳解Golang編程中的常量與變量
  • Golang開發中如何解決共享變量問題

標簽:安康 青海 物業服務 遼寧 電子產品 西雙版納 海南 儋州

巨人網絡通訊聲明:本文標題《淺談golang并發操作變量安全的問題》,本文關鍵詞  淺談,golang,并發,操作,變量,;如發現本文內容存在版權問題,煩請提供相關信息告之我們,我們將及時溝通與處理。本站內容系統采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《淺談golang并發操作變量安全的問題》相關的同類信息!
  • 本頁收集關于淺談golang并發操作變量安全的問題的相關信息資訊供網民參考!
  • 推薦文章
    主站蜘蛛池模板: 51黑料网永久入口| 没带罩子让他玩儿了一天| 沽源县| 特级精品毛片免费观看| 色偷偷资源网| 情欲满载完整版手机在线播放| 每天都被家具做| 看美女裸体??免费软件| 成人做爰高潮片免费看视频道具| 无码人妻精品一区二区中文| 欧美深到肚子的全臂交| xxxx欧美xxxx黑人| 里番本子侵犯肉全彩A片男男| 边吃奶水边添下面好爽| 高跟丝袜美女一级毛片| 欧美精品一线二线大片| 乳巨揉みま痴汉电车中文字幕| 亚洲精品9999久久久久| 被精夜浸濡的小柔| 色www永久免费网站国产| 男男肉菊粗暴进入| 麻麻夹得好紧…爽死我了视频| 婷婷久久综合久色综合| 一女被各种np小黄文| 日日操网站| 日韩欧美综合在线二区三区| 久久精品亚洲青青草原| 国产精品久久久久久久模特李静怡| 高H 重口 激H 慎宫交H| 极品美女洗澡后露粉嫩木耳视频| 草原之夜原唱| 淫男乱女阅读| 女人又爽?又黄?触手动漫| 特黄特色大片免费播放丶| 亚洲一区高清| 适合两个人运动前看的电影美国| 丝袜美足国产一区在线| 娇妻玩4P被3个男子伺候91| 一级a一级a爰片免费免| 波多野结衣_紧身裙女人教师 | 女仆被各种器具残忍调教|