Golang 中的 atomic.LoadPointer()函数示例

在 Go 语言中，原子包提供较低级别的原子内存，这有助于实现同步算法。 Go 语言中的LoadPointer()函数用于自动加载*addr 。这个函数是在 atomic 包下定义的。在这里，您需要导入“sync/atomic”和“unsafe”包才能使用这些功能。

句法：

func LoadPointer(addr *unsafe.Pointer) (val unsafe.Pointer)

这里， addr表示地址。

注意： (*unsafe.Pointer) 是指向unsafe.Pointer值的指针。 unsafe.Pointer类型有助于实现任意类型和内置uintptr类型之间的转换。此外，unsafe 是一个有助于 Go 程序类型安全的包。

返回值：它自动加载 *addr 并返回unsafe.Pointer 。

示例 1：

// Program to illustrate the usage of
// LoadPointer function in Golang
  
// Including main package
package main
  
// importing fmt, 
// sync/atomic and unsafe
import (
    "fmt"
    "sync/atomic"
    "unsafe"
)
  
// Defining a struct type L
type L struct{ x, y, z int }
  
// Declaring pointer 
// to L struct type
var PL *L
  
// Calling main
func main() {
  
    // Defining *addr unsafe.Pointer
    var unsafepL = (*unsafe.Pointer)(unsafe.Pointer(&PL))
  
    // Defining value 
    // of unsafe.Pointer
    var px L
  
    // Calling StorePointer and 
    // storing unsafe.Pointer
    // value to *addr
    atomic.StorePointer(
        unsafepL, unsafe.Pointer(&px))
  
    // Calling LoadPointer() method
    px1 := (*L)(atomic.LoadPointer(unsafepL))
  
    // Returns true if *addr is 
    // loaded else returns false
    fmt.Println(px1 == &px)
  
    // Prints unsafe.Pointer
    fmt.Println(&px1)
}

输出：

true
0xc0000b8018 // Can be different at different run times

在这里， StorePointer方法将值添加到*addr ，然后LoadPointer方法以原子方式加载 *addr。所以，这里加载完成，因此返回 true 并且这里返回的unsafe.Pointer的值在不同的运行时间可能会有所不同。

示例 2：

// Program to illustrate the usage of
// LoadPointer function in Golang
  
// Including main package
package main
  
// importing fmt, 
// sync/atomic and unsafe
import (
    "fmt"
    "sync/atomic"
    "unsafe"
)
  
// Defining a struct type L
type L struct{ x, y, z int }
  
// Declaring pointer 
// to L struct type
var PL *L
  
// Calling main
func main() {
  
    // Defining *addr unsafe.Pointer
    var unsafepL = (*unsafe.Pointer)(unsafe.Pointer(&PL))
  
    // Defining value 
    // of unsafe.Pointer
    var px L
  
    // Calling LoadPointer() method
    px1 := (*L)(atomic.LoadPointer(unsafepL))
  
    // Returns true if *addr is 
    // loaded else returns false
    fmt.Println(px1 == &px)
  
    // Prints unsafe.Pointer
    fmt.Println(&px1)
}

输出：

false
0xc00000e028  // A random value is returned in each run

此处，返回 false 是因为 unsafe.pointer 之前未存储，因此LoadPointer() 方法无法加载*addr 。而且，这里返回的地址值是px1的地址。