预先初始化

在外部var初始化

package main

import (
    "fmt"
    "time"
)

var startTime = time.Now()

func main() {
    fmt.Println(startTime)
}

在init函数初始化

package main

import (
    "fmt"
    "time"
)

var startTime time.Time

func init() {
    startTime = time.Now()
}

func main() {
    fmt.Println(startTime)
}

在main函数执行自定义初始化函数

package main

import (
    "fmt"
    "time"
)

var startTime time.Time

func initApp() {
    startTime = time.Now()
}

func main() {
    initApp()
    fmt.Println(startTime)
}
延迟加载仅初始化一次(单例)

加锁实现

虽然达到要求了,但是有性能问题,因为每一次请求者要竞争锁才能读取到这个连接
其实创建好连接之后,就不需要锁的保护了


var connMu sync.Mutex
var conn net.Conn

func getConn() net.Conn {
    connMu.Lock()
    defer connMu.Unlock()

    if conn != nil {
        return conn
    }
    conn,_ = net.DialTimeout("tcp","baidu.com:80",10*time.Second)
    return conn
}

func main() {
    conn := getConn()
    if conn != nil {
        panic("conn is nil")
    }
}

标准库Once实现

package main

import (
    "net"
    "sync"
)

var conn net.Conn
var once sync.Once

func getConn() net.Conn {
    var err error
    once.Do(func() {
        conn, err = net.Dial("tcp", "baidu.com")
    })
    return conn
}

func main() {
    conn := getConn()
    if conn != nil {
        panic("conn is nil")
    }
}

自定义Once实现

Once实现的逻辑有一个缺陷,就是当f函数初始化失败后,以后就不会再执行了,我们其实可以在Once里加入当f函数不返回error的时候才代表初始化完成了
另外,我们还可以返回Done检察是否已经初始化完成了

package main

import (
    "errors"
    "fmt"
    "sync"
    "sync/atomic"
)

type Once struct {
    done uint32
    m sync.Mutex
}

func (o *Once) Do(f func() error) error {
    if atomic.LoadUint32(&o.done) == 0 {
        return o.doSlow(f)
    }
    return nil
}

func (o *Once) doSlow(f func() error) (err error) {
    o.m.Lock()
    defer o.m.Unlock()
    if o.done == 0 {
        if err = f(); err == nil {
            defer atomic.StoreUint32(&o.done, 1)
        }
    }
    return err
}
//再加入一个判断Once是否执行完的方法
func (o *Once) Done() bool {
    return atomic.LoadUint32(&o.done) == 1
}

func main() {
    var once Once
    once.Do(func() error {
        fmt.Println("one")
        return errors.New("one error")
    })
    fmt.Println(once.Done())
    once.Do(func() error {
        fmt.Println("two")
        return nil
    })
    fmt.Println(once.Done())
}