go map 源码

  • 2022-07-15
  • 浏览 (829)

golang map 代码

文件路径:/src/runtime/testdata/testprog/map.go

// Copyright 2016 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package main

import "runtime"

func init() {
	register("concurrentMapWrites", concurrentMapWrites)
	register("concurrentMapReadWrite", concurrentMapReadWrite)
	register("concurrentMapIterateWrite", concurrentMapIterateWrite)
}

func concurrentMapWrites() {
	m := map[int]int{}
	c := make(chan struct{})
	go func() {
		for i := 0; i < 10000; i++ {
			m[5] = 0
			runtime.Gosched()
		}
		c <- struct{}{}
	}()
	go func() {
		for i := 0; i < 10000; i++ {
			m[6] = 0
			runtime.Gosched()
		}
		c <- struct{}{}
	}()
	<-c
	<-c
}

func concurrentMapReadWrite() {
	m := map[int]int{}
	c := make(chan struct{})
	go func() {
		for i := 0; i < 10000; i++ {
			m[5] = 0
			runtime.Gosched()
		}
		c <- struct{}{}
	}()
	go func() {
		for i := 0; i < 10000; i++ {
			_ = m[6]
			runtime.Gosched()
		}
		c <- struct{}{}
	}()
	<-c
	<-c
}

func concurrentMapIterateWrite() {
	m := map[int]int{}
	c := make(chan struct{})
	go func() {
		for i := 0; i < 10000; i++ {
			m[5] = 0
			runtime.Gosched()
		}
		c <- struct{}{}
	}()
	go func() {
		for i := 0; i < 10000; i++ {
			for range m {
			}
			runtime.Gosched()
		}
		c <- struct{}{}
	}()
	<-c
	<-c
}

相关信息

go 源码目录

相关文章

go abort 源码

go badtraceback 源码

go checkptr 源码

go crash 源码

go crashdump 源码

go deadlock 源码

go gc 源码

go lockosthread 源码

go main 源码

go memprof 源码

0  赞