文档章节

初识goroutine

秋风醉了
 秋风醉了
发布于 2016/07/15 11:47
字数 789
阅读 12
收藏 0
点赞 0
评论 0

初识goroutine

Go语言通过goroutine提供了目前为止所有语言里对于并发编程的最清晰最直接的支持。

  1. **goroutine是Go语言运行库的功能,不是操作系统提供的功能,goroutine不是用线程实现的。**具体可参见Go语言源码里的pkg/runtime/proc.c
  2. **goroutine就是一段代码,一个函数入口,以及在堆上为其分配的一个堆栈。**所以它非常廉价,我们可以很轻松的创建上万个goroutine,但它们并不是被操作系统所调度执行
  3. 除了被系统调用阻塞的线程外,Go运行库最多会启动$GOMAXPROCS个线程来运行goroutine

goroutine从上面总结来看,其不是用线程实现的,只是一段代码,一个函数的入口,以及在堆上为其分配的一个堆栈。 goroutine是一个并发执行的单元。当一个程序启动时,其主函数即在一个单独的goroutine中运行,我们叫它main goroutine。新的goroutine会用go语句来创建。在语法上,go语句是一个普通的函数或方法调用前加上关键字go。go语句会使其语句中的函数在一个新创建的goroutine中运行。而go语句本身会迅速地完成。如下示例,

package main

import (
	"fmt"
)

func loop() {
	for i := 0; i < 10; i++ {
		fmt.Printf("%d ", i)
	}
}

func main() {
	go loop() //create a new goroutine that calls loop(); don't wait
	loop()    //call loop(); wait for it to return
}

运行结果,

[ `go  run  goroutine.go` | done: 336.67264ms ]
	0 1 2 3 4 5 6 7 8 9

可以看到,只输出了一个loop,其实是goroutine执行的loop没有输出,这是因为当main goroutine退出的时候,所有的goroutine都会被直接打断,程序退出。除了从主函数退出或者直接终止程序之外,没有其它的编程方法能够让一个goroutine来打断另一个的执行。 有什么办法能让goroutine 执行完成后让程序退出,简单的方法就是让main goroutine阻塞一会,如下,

package main

import (
	"fmt"
	"time"
)

func loop() {
	for i := 0; i < 10; i++ {
		fmt.Printf("%d ", i)
	}
}

func main() {
	go loop() //create a new goroutine that calls loop(); don't wait
	loop()    //call loop(); wait for it to return

	time.Sleep(time.Second) //让主函数阻塞

}

goroutine case 1

使用goroutine实现并发的Clock服务,如下代码,

package main

import (
	"fmt"
	"io"
	"log"
	"net"
	"time"
)

// handleConn函数会处理一个完整的客户端连接
// 会执行循环,而不会退出,那么就会阻碍后面的连接
func handleConn(c net.Conn) {
	defer c.Close()
	for {
		_, err := io.WriteString(c, time.Now().Format("15:04:05\n"))
		if err != nil {
			return // e.g., client disconnected
		}
		time.Sleep(1 * time.Second)
	}
}

func main() {

	listener, err := net.Listen("tcp", "127.0.0.1:9090")

	if err != nil {
		log.Fatal(err)
	}

	for {
		conn, err := listener.Accept() //istener对象的Accept方法会直接阻塞,直到一个新的连接被创建,然后会返回一个net.Conn对象来表示这个连接。
		fmt.Println("accept...")
		if err != nil {
			log.Print(err)
			continue
		}

		handleConn(conn) // handle one connection at a time
	}

}

如程序注释描述的一样,一次只能处理一个连接,怎么样才能并发的处理多个连接呢?使用goroutine,只需简单的在 handleConn()方法前面加一个go 关键字。

==========END==========

© 著作权归作者所有

共有 人打赏支持
秋风醉了
粉丝 228
博文 577
码字总数 407134
作品 0
朝阳
程序员
公开课|一个小运维的《Golang 入门心路历程》

成功不是将来才有的,而是从决定去做的那一刻起,持续累积而成。 视频版 公开课主要内容: 缘起 初识 熟悉 实践 爱上 缘起 本人之前是 hadoop hbase 运维,为了节约成本 hadoop client 都是多...

xjtuhit
2017/09/15
0
0
NSQ系列之nsqlookupd代码分析一(初探nsqlookup)

NSQ系列之nsqlookupd代码分析一(初探nsqlookup) 是守护进程负责管理拓扑信息。客户端通过查询 来发现指定话题()的生产者,并且提供 节点广播话题()和通道()信息。 有两个接口: 接口...

大蓝妹
2015/08/27
0
0
golang: beego自动化部署

springboot: springboot+mongodb+docker实例 golang: beego自动化部署 数据库管理平台NetopGO简介 Go语言开发 Go语言圣经(中文版) Go语言(golang)开源项目大全 Go语言诞生5周年!10大Go语言...

d_watson
2016/05/20
233
0
Ext.Error: Unable to parse the JSON returned by the server: You're trying to decode an invalid JSON String

Firefox给出的错误 Ext.Error: Unable to parse the JSON returned by the server: You're trying to decode an invalid JSON String:...

anonymous_007
2014/05/28
1K
2
论go语言中goroutine的使用

go中的goroutine是go语言在语言级别支持并发的一种特性。初接触go的时候对go的goroutine的欢喜至极,实现并发简便到简直bt的地步。但是在项目过程中,越来越发现goroutine是一个很容易被大家...

王二狗子11
01/08
0
0
当我们在谈论Golang的并发时,实际上在谈论什么?

并发(Concurrency) 大家都知道,通常情况下一个简单的串行执行的程序在计算机内部被执行的时候是按照指令的顺序一步一步执行,这种情况下CPU在每一条指令必须执行结束才会有下一条指令被执...

艾文西
07/09
0
0
转Elasticsearch顶尖高手系列课程

Elasticsearch,是目前行业中非常热门的一个技术。Elasticsearch是一种分布式的海量数据搜索与分析的技术,可以用于电商网站、门户网站、企业IT系统等各种场景下的搜索引擎,也可以用于对海量...

小花卷juan
2017/06/24
124
0
Go基础编程:并发编程—goroutine

1 goroutine是什么 goroutine是Go并行设计的核心。goroutine说到底其实就是协程,但是它比线程更小,十几个goroutine可能体现在底层就是五六个线程,Go语言内部帮你实现了这些goroutine之间的...

tennysonsky
01/15
0
0
学习笔记:channel的初步理解

channel会阻塞,阻塞的时候系统会继续顺序调用其他goroutine,main()也是一个goroutine,只是最先被执行。 看一个代码: 这段代码输出结果: 首先执行main函数,它是第一个goroutine,在mai...

吾爱
2014/10/09
0
0
Go语言学习笔记(七)杀手锏 Goroutine + Channel

Goroutine Go语言的主要的功能在于令人简易使用的并行设计,这个方法叫做Goroutine,通过Goroutine能够让你的程序以异步的方式运行,而不需要担心一个函数导致程序中断,因此Go语言也非常地适...

wangxuwei
01/29
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

实现异步有哪些方法

有哪些方法可以实现异步呢? 方式一:java 线程池 示例: @Test public final void test_ThreadPool() throws InterruptedException { ScheduledThreadPoolExecutor scheduledThre......

黄威
今天
0
0
linux服务器修改mtu值优化cpu

一、jumbo frames 相关 1、什么是jumbo frames Jumbo frames 是指比标准Ethernet Frames长的frame,即比1518/1522 bit大的frames,Jumbo frame的大小是每个设备厂商规定的,不属于IEEE标准;...

六库科技
今天
0
0
牛客网刷题

1. 二维数组中的查找(难度:易) 题目描述 在一个二维数组中(每个一维数组的长度相同),每一行都按照从左到右递增的顺序排序,每一列都按照从上到下递增的顺序排序。请完成一个函数,输入...

大不了敲一辈子代码
今天
0
0
linux系统的任务计划、服务管理

linux任务计划cron 在linux下,有时候要在我们不在的时候执行一项命令,或启动一个脚本,可以使用任务计划cron功能。 任务计划要用crontab命令完成 选项: -u 指定某个用户,不加-u表示当前用...

黄昏残影
昨天
0
0
设计模式:单例模式

单例模式的定义是确保某个类在任何情况下都只有一个实例,并且需要提供一个全局的访问点供调用者访问该实例的一种模式。 实现以上模式基于以下必须遵守的两点: 1.构造方法私有化 2.提供一个...

人觉非常君
昨天
0
0
《Linux Perf Master》Edition 0.4 发布

在线阅读:https://riboseyim.gitbook.io/perf 在线阅读:https://www.gitbook.com/book/riboseyim/linux-perf-master/details 百度网盘【pdf、mobi、ePub】:https://pan.baidu.com/s/1C20T......

RiboseYim
昨天
1
0
conda 换源

https://mirrors.tuna.tsinghua.edu.cn/help/anaconda/ conda config --add channels https://mirrors.tuna.tsinghua.edu.cn/anaconda/pkgs/free/conda config --add channels https://mir......

阿豪boy
昨天
1
0
Confluence 6 安装补丁类文件

Atlassian 支持或者 Atlassian 缺陷修复小组可能针对有一些关键问题会提供补丁来解决这些问题,但是这些问题还没有放到下一个更新版本中。这些问题将会使用 Class 类文件同时在官方 Jira bug...

honeymose
昨天
0
0
非常实用的IDEA插件之总结

1、Alibaba Java Coding Guidelines 经过247天的持续研发,阿里巴巴于10月14日在杭州云栖大会上,正式发布众所期待的《阿里巴巴Java开发规约》扫描插件!该插件由阿里巴巴P3C项目组研发。P3C...

Gibbons
昨天
1
0
Tomcat介绍,安装jdk,安装tomcat,配置Tomcat监听80端口

Tomcat介绍 Tomcat是Apache软件基金会(Apache Software Foundation)的Jakarta项目中的一个核心项目,由Apache、Sun和其他一些公司及个人共同开发而成。 java程序写的网站用tomcat+jdk来运行...

TaoXu
昨天
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部