golang并发知识点总结
1. go申明 goroutine，也可以申明匿名函数，就表示开启多协程并发访问
2. go多个goroutine通信,使用channel，必须用 info:=make(chan string) 格式定义，即用make关键字
3. go申明的并发访问方法，要考虑多个协程同时执行对公共资源的占用和读写，如磁盘读写，网络访问，数据库访问等，下面例子体现并发访问导致的“事务不一致”问题，以及解决方法
4. golang 加锁机制非常轻量简洁 。
go 共享锁定义 mutex := &sync.Mutex{} 传递锁的指针，要注意多个协程要用一个共享锁，传入不同的锁，不能达到加锁的功能。
实例看懂并发和锁
const (openLock = true)func main2() {gfile.PutContents("content.txt", "")concurrency()chuan()}func chuan() {gproc.StartTime()//串行访问十次 非并发，每次协程id不变for i := 0; i < 10; i++ {info := goMethod1("串行", nil)glog.Debug(info)}glog.Info("串行访问十次结束,耗时:", gproc.Uptime())}func concurrency() {//取锁地址mutex := &sync.Mutex{}gproc.StartTime()//并发访问十次//info:=make(chan string)for i := 0; i < 10; i++ {//传递共享锁指针go goMethod1("并行", mutex)}glog.Info("并发访问十次结束,耗时:", gproc.Uptime())}//这里的锁是来自上层主线程的共享锁func goMethod1(mtype string, mutex *sync.Mutex) string {if mutex != nil && openLock {mutex.Lock()defer mutex.Unlock()}info := mtype + "访问协程id:" + (strconv.FormatUint(GetGoroutineID(), 10)) + "\r\n"gutil.TryCatch(func() {//故意写入两次体验锁机制保证每一个协程事务一致，锁机制gfile.PutContentsAppend("content.txt", info)gfile.PutContentsAppend("content.txt", info)}, func(exception interface{}) {glog.Error(exception)})return info}func GetGoroutineID() uint64 {b := make([]byte, 64)runtime.Stack(b, false)b = bytes.TrimPrefix(b, []byte("goroutine "))b = b[:bytes.IndexByte(b, ' ')]n, _ := strconv.ParseUint(string(b), 10, 64)return n}不加锁文件内容
加锁以后文件内容
结果分析
上面代码执行两种结果如图所示。
不加锁文件内容：方法写入的两句话没法连续写入文件。
加锁以后文件内容：方法写入的两句话连续写入文件。
有锁，就可以保障方法对共享资源的“事务一致性”。
本文来自投稿，不代表本人立场，如若转载，请注明出处：http://www.souzhinan.com/kj/288686.html