代码如下： package main import ( "container/list" "fmt" "time" ) var Ch = make(chan int) var DataList = list.New() func ReadChan() { for { data := <-Ch fmt.Println(data) } } func WriteChan() { for { if size := DataList.Len(); size > 0 { data := DataList.Front() if data.Value != nil { Ch <- data.Value.(in...阅读全文
golang的多线程固然好用，但是有时候需要对数据进行上锁，防止数据被其它线程更改。那么sync包下的Mutex非常好用。 Mutex是一个互斥锁。可以作为struct的一部分，这样这个struct就会防止被多线程更改数据。 来个例子： package main import ( "fmt" "sync" "time" ) type User struct { Name string Locker *sync.Mutex } func (u *User) SetName(wati *sync.WaitGroup, name string) { defer func() { fmt.Println("Unlock set name:", name) u.Locker.Unlock() wati...阅读全文
