go多线程实现的两种方法

2017-11-8 16:02| 发布者: admin| 查看: 66| 评论: 0

摘要: MicrosoftInternetExplorer402DocumentNotSpecified7.8 磅Normal0想学习go语言的同学们,大家好好看看吧,希望能对大家有帮助。一、go多线程实现方法之一:channel申明一个channel,并发产生的业务放入channel中,启 ...

想学习go语言的同学们,大家好好看看吧,希望能对大家有帮助。

一、go多线程实现方法之一:channel

申明一个channel,并发产生的业务放入channel中,启动一个或者多个goroutime读取channel中的数据并处理。

如何实现一个线程池。代码及注释如下:

package main

import "fmt"

import "time"

//工作线程,处理具体的业务逻辑,是将jobs中的任务取出,处理后将处理结果放置在results中。

func worker(id int, jobs <-chan int, results chan<- int) {

for j := range jobs {

fmt.Println("worker", id, "processing job", j)

time.Sleep(time.Second)

results <- j * 2

}

}

func main() {

//两个channel,一个用来放置工作项,一个用来存放处理结果。

jobs := make(chan int, 100)

results := make(chan int, 100)

// 开启三个线程,也就是说线程池中只有3个线程,实际情况下,我们可以根据需要动态增加或减少线程。

for w := 1; w <= 3; w++ {

go worker(w, jobs, results)

}

// 添加9个任务后关闭Channel

// channel to indicate that's all the work we have.

for j := 1; j <= 9; j++ {

jobs <- j

}

close(jobs)

//获取所有的处理结果

for a := 1; a <= 9; a++ {

<-results

}

}


输出结果:

worker 1 processing job 1

worker 2 processing job 2

worker 3 processing job 3

worker 1 processing job 4

worker 3 processing job 5

worker 2 processing job 6

worker 1 processing job 7

worker 2 processing job 8

worker 3 processing job 9

从中可以看出,多个线程轮流处理了9个任务。

通过这个例子,我们可以学习到:

1、GO中多线程应用开发非常简单。

2、Channel是不同线程间数据交互的利器。 上面的例子中,主线程向jobs中写数据,三个工作线程同时从一个Channel中取数据。

go语言之多线程

二、go多线程实现方法之二:goroutine

每一个新的请求,都启动一个新的goroutine来处理,处理结束后关闭goroutine。

对于初学者,goroutine直接理解成为线程就可以了。当对一个函数调用go,启动一个goroutine的时候,就相当于起来一个线程,执行这个函数。

实际上,一个goroutine并不相当于一个线程,goroutine的出现正是为了替代原来的线程概念成为最小的调度单位。一旦运行goroutine时,先去当先线程查找,如果线程阻塞了,则被分配到空闲的线程,如果没有空闲的线程,那么就会新建一个线程。注意的是,当goroutine执行完毕后,线程不会回收推出,而是成为了空闲的线程。

使用非常简单,在函数前增加一个go,值得注意的是一个goroutine结束后必须要向主线程传输数据,告诉主线程这个goroutine已经结束了。

对于一般业务,用两种模式都差不多。主要区别在于:

第一种模式请求不一定是实时响应的,如果处理的逻辑中有阻塞,当所有goroutime都被阻塞时,系统运行就出问题了。

 

第二种模式每个goroutime都是独立的,互不影响,而且实时响应。但是频繁的新建和销毁goroutime会有性能损耗,不过go语言中goroutime是很轻量级的,这并不会带来太大的问题。

 


鲜花

握手

雷人

路过

鸡蛋

最新评论(0)

Powered by Discuz! X3.2  © 2001-2013 Comsenz Inc.