Golang并发初探

作者: calvinxiao | 来源:发表于2016-05-13 00:23 被阅读0次

演员表

  • 马恩 // main goroutine, 每个go程序至少有一个goroutine
  • 高老丁1 // 一个去买尿片的goroutine
  • 高老丁2 // 一个去买啤酒的goroutine
  • 思除 // ch(channel), 用于goroutine之间只能用channel通讯

事情发生经过

  1. 马恩把思除叫来
  2. 马恩把思除的微信号告诉高老丁1,然后高老丁1就去买尿片了,回来放好尿片之后就微信一下思除
  3. 马恩吧思除的微信号告诉高老丁2,然后高老丁2就去买啤酒了,回来放好啤酒之后就微信一下思除(咦,超市不是一般都会吧尿片和啤酒放在一起的么?为什么要两个人去)
  4. 然后马恩就盯着思除,但是思除的手机一直都不响
  5. 突然间思除的手机响了
  6. 突然间思除的手机响了
  7. 马恩知道尿片和啤酒都买回来了

上面就知最简单的go并发通讯例子。


附上一段并发排序的例子 gist
排序1000万个数字,go library的sort用时3.75秒,把数组分开两边同时用goroutine先排序再合并用时1.98秒

/**
 * a sort demo while learning go goroutine
 * sorting 10 million numbers concurrently
*/

package main

import (
    "fmt"
    "sort"
    "math/rand"
    "time"
)

type IntS []int

// sort.Interface
func (a IntS) Len() int {
    return len(a)
}

func (a IntS) Swap(i, j int) {
    a[i], a[j] = a[j], a[i]
}

func (a IntS) Less(i, j int) bool {
    return a[i] < a[j]
}
// end sort.Interface

const n = 10000000 // 1e7

func main() {
    var a = IntS{}
    var b = IntS{}
    for i := 0; i < n; i++ {
        var t = rand.Intn(n)
        a = append(a, t)
        b = append(b, t)
    }

    var start1 = time.Now()
    sort.Sort(a)
    fmt.Printf("pkg sort took %.6f seconds\n", time.Since(start1).Seconds())

    var start2 = time.Now()
    superSort(b)
    fmt.Printf("sup sort took %.6f seconds\n", time.Since(start2).Seconds())

}

// super sort with goroutine
func superSort(a IntS) IntS {
    length := len(a)
    if length <= 1 {
        return a
    }

    mid := length / 2
    a1 := a[0: mid]
    a2 := a[mid: length]

    var ch = make(chan int)

    go func() {
        sort.Sort(a1)
        ch <- 1
    }()

    go func() {
        sort.Sort(a2)
        ch <- 1
    }()

    <- ch
    <- ch

    a3 := make([]int, length)
    var i, j, n1, n2 int
    n1 = len(a1)
    n2 = len(a2)
    // merge two sorted list
    for ii := 0; ii < length; ii++ {
        if (i < n1 && j < n2 && a1[i] < a2[j]) || (i < n1 && j == n2) {
            a3[ii] = a1[i]
            i++
            continue
        }

        a3[ii] = a2[j]
        j++
    }

    return a3
}

//[calvin:~/source/test/go]$ go run sort.go
//pkg sort took 3.754109 seconds
//sup sort took 1.980207 seconds

相关文章

  • Golang并发初探

    演员表 马恩 // main goroutine, 每个go程序至少有一个goroutine 高老丁1 // 一个...

  • Golang的并发编程

    golang是为并发而生的语言。优雅的并发编程范式,完善的并发支持,出色的并发性能是golang区别于其他语言的一...

  • Go append并发问题

    Golang append并发问题

  • golang语言map的并发和排序

    golang语言map的并发和排序 map的并发问题 golang缺省的map不是thread safe的,如果存...

  • 说说Golang goroutine并发那些事儿

    摘要:今天我们一起盘点一下Golang并发那些事儿。 Golang、Golang、Golang 真的够浪,今天我们...

  • 并发 concurrency golang

    原文链接:并发concurrency-GOLANG

  • 初探 golang

    学习一门语言我认为安装部署可以先跳过,把时间精力放在逻辑上和基础知识点上会更好,部署环境以后再说。 看了几集的视频...

  • 从java的角度看golang并发(web server方面)

    从java的角度看golang在并发方面的特点,先从最顶层的线程模型开始,结合线程模型看golang的并发优势,最...

  • 初探golang-GOLANG

    golang -@amazeUI -2017-05-20 17:49:08 学习一门语言我认为安装部署可以先跳过,...

  • Golang的并发编程

    Golang中的并发编程 Golang语言中,并发使用的协程的机制,实现起来也是十分的方便,使用go关键字即可。 ...

网友评论

    本文标题:Golang并发初探

    本文链接:https://www.haomeiwen.com/subject/uabprttx.html