golang线程教程

Go语言（Golang）是一种由谷歌开发的开源编程语言，它具有高效、简洁和并发性，非常适合用于构建网络服务和分布式系统。在Golang中，线程被称为goroutine，它是一种轻量级的用户态线程，通过go关键字来启动。与传统的操作系统线程相比，goroutine拥有更小的栈空间，更快的启动和销毁速度，以及更高效的调度机制。

1. goroutine的创建和调度

在Golang中，使用关键字go可以启动一个新的goroutine。下面是一个简单的例子：

func main() {
    go hello()
    fmt.Println("main function")
}

func hello() {
    fmt.Println("hello goroutine")
}

在这个例子中，main函数启动了一个新的goroutine来执行hello函数，而不需要等待hello函数执行完毕。这意味着，我们可以在主线程中并发地执行多个任务。

2. goroutine的通信机制——通道

在goroutine之间进行通信是一种常见的需求，Golang提供了一种称为通道（Channel）的机制来满足这个需求。通道是一种类型化的管道，用于在goroutine之间传递数据。下面是一个简单的例子：

func main() {
    ch := make(chan int)
    go func() {
        ch <- 1
        ch <- 2
        ch <- 3
    }()
    fmt.Println(<-ch)
    fmt.Println(<-ch)
    fmt.Println(<-ch)
}

在这个例子中，我们创建了一个整型的通道ch，并通过go关键字启动了一个新的goroutine。在新的goroutine中，我们向通道ch发送了三个整数。在主线程中，我们使用<-运算符从通道ch中接收数据，并打印出来。

3. goroutine之间的同步——互斥锁

在并发编程中，多个goroutine访问共享资源时可能会发生竞争条件的问题。为了避免竞争条件，Golang提供了一种称为互斥锁（Mutex）的机制。互斥锁可以保护临界区，使得只有获得锁的goroutine才能进入临界区进行操作。下面是一个简单的例子：

var counter int
var mutex sync.Mutex

func main() {
    wg := sync.WaitGroup{}
    for i := 0; i < 1000; i++ {
        wg.Add(1)
        go increment(&wg)
    }
    wg.Wait()
    fmt.Println("counter:", counter)
}

func increment(wg *sync.WaitGroup) {
    mutex.Lock()
    counter++
    mutex.Unlock()
    wg.Done()
}

在这个例子中，我们使用互斥锁mutex来保护counter变量的访问。在每次goroutine执行增加操作之前，我们使用Lock方法获得锁，在增加操作完成之后，使用Unlock方法释放锁。同时，我们使用sync包中的WaitGroup来确保所有的goroutine都执行完毕。