----------------------------------------- go 并发
// 注解:go 语言天生为程序并发所设计,可以说go的强项就是在cpu并发上的处理。
// go 语言层面就支持了并发。(不是一般高级语言的多线程并发,是系统级真实并发)
// go 语言通过安全的通道发送和接受数据以实现同步
// 一般情况下,一个普通的桌面计算机跑十几二十几个线程就有点负载过大了,但是同样的硬件设备go可以轻松上K。
----------------------------------------- goroutine
// 注解:go 并发设计的核心,goroutine在并发中起到的作用就是协程(CSP),但是它比线程更小。(协程=微线程)
// go 不支持后台协程,意思就是主程序退出,协程跟着一起退出
func newTask() {
for {
fmt.Println("new task ...")
time.Sleep(time.Second) // 休眠1s
}
} func main() {
go newTask() // 新建一个协程,新建一个任务 for {
fmt.Println("main ...")
time.Sleep(time.Second) // 休眠1s
}
}
// result :
// main...
// new task ...
// ....
----------------------------------------- gosched
// 注解:让出CPU时间片,让出当前 gorotine 的执行权限,
// 调度器安排其他等待任务运行,并在下次某个时候从该位置恢复执行。
func main() {
go func() {
for i := ; i < ; i++ {
fmt.Println("go")
}
}() for i := ; i < ; i++ {
fmt.Println("hello")
} // 这种情况,匿名函数未得到执行程序就结束了。
// 时间片案例演示代码,修改如下:
for i := .... {
runtime.Gosched()
fmt.Println("hello")
}
// 执行结果:
// go go ... hello ..
}
----------------------------------------- goexit
import "runtime"
// 注解:终止所在的协程 (所在的协程不是当前函数)
func test() {
defer fmt.Println("ccccc")
runtime.Goexit()
fmt.Println("dddd")
} func main() {
go func (){
fmt.Println("aaaa")
test()
fmt.Println("bbbb")
}
for {
} // result:
// aaaa cccc
}
----------------------------------------- gomaxProcs
// 注解:设置可以并行计算的 CPU 核数的最大值
import "runtime" func main() {
n := runtime.GOMAXProcs() //制定以1核运算
fmt.Println("n = ", n) for {
go fmt.Print()
fmt.Print()
} // 打印结果:11111.. 一大片, 00000...一大片
// 如果设置 GOMAXProcs(4) 为 4 核交叉效果更好
}
----------------------------------------- 资源争夺问题 channel
// 注解:channel 也是一种数据类型,同步
// 语法:channel <- value // 发送 value 数据到 channel
// <- channel // 接收并丢弃 // 案例:
// 全局变量,创建一个 channel
var ch = make(chan int) // 定义一个打印机,参数为字符串,按每个字符打印
func Printer(str string) {
for _, data := range str {
fmt.Printf("%c", data)
time.Sleep(time.Second)
}
fmt.Printf("\n")
} func person1() {
Printer("loong print")
ch <- // 给管道写数据
} func person2() {
<- ch // 从管道取数据,如果管道没有数据前他就会阻塞
Printer("make print")
} func main() {
// 新建 2 个协程,代表 2 个人,2 个人同时使用打印机
go person1()
go person2()
}
// 注解: 【认真看】
// 没有 channel 的情况
// 打印结果混乱,person1 打印一个h,person2 打印一个 w,交叉了。不符合我们的要求
// 增加 channel ,则在 <-ch 的地方进行了阻塞,通过进、出的方式融合这种解决这种并发互抢资源的问题。
----------------------------------------- channel 实现同步和数据交互
fun main() {
ch := make(chan string) defer fmt.Println("主协程也结束") go func() {
defer fmt.Println("子协程调用完毕。") for i := ; i < ; i++ {
fmt.Println("子协程 i=", i)
time.Sleep(time.Second)
} ch <- "我是子协程,工作完毕"
} str := <-ch // 没有数据前,阻塞
fmt.Println("str = ", str)
} // 注意:程序需求:主程序结束之前,能够完整执行匿名函数中的代码
// 使用 channel 配合完成
----------------------------------------- channel 无缓存&有缓存
c1 := make(chan int) 无缓冲
c2 := make(chan int,) 有缓冲
c1 < -
// 无缓冲:不仅仅是向 c1 通道放 1,
// 而是一直要等有别的协程 <-c1 接手了这个参数,那么c1<-1才会继续下去,要不然就一直阻塞着。
// 有缓冲: c2<-1 则不会阻塞,因为缓冲大小是1(其实是缓冲大小为0),
// 只有当放第二个值的时候,第一个还没被人拿走,这时候才会阻塞。 // 不需要再使用记得关闭channel close(c1)
// 判断管道是否关闭 if num, ok := <- c1; ok == true { // 关闭了 } ----------------------------------------- channel 单方向
var ch1 chan int // ch1 是一个正常的 channle,不是单向的
var ch2 chan<- float64 // ch2 是单向 channel,只用于写 float64 数据
var ch3 <-chan int // ch3 是单向 channel,只用于读取 int 数据 // * 管道的操作,一定要避免死锁的情况。
----------------------------------------- channel 应用
// 此案例可以应用很多场景,每写一个,则可以消耗一个
// 此通道只能写,不能读
func producer(out chan<- int) {
for i := ; i < ; i++ {
out <- i * i
} close(out)
} // 此通道只能读,不能写
func consumer(in <-chan int) {
for num := range in {
fmt.Println("num = ", num)
}
} func main() {
// 创建一个双向通道
ch := make(chan int) // 生产者,生产数字,写入 channel
// 开启一个协程
go producer(ch) // 消费者,从channel读取内容打印
consumer(ch)
}
----------------------------------------- Timer
import (
"time"
"fmt"
) func main() {
// 创建一个定时器,设置时间为2s,2s后,往time通道写内容
timer := time.NewTimer( * time.Second)
fmt.Println("当前时间:", time.Now()) // 2s后,往timer.C写数据,有数据后读取
t := <-time.C // channel 没有数据前后阻塞
fmt.Println("t = ", t)
}
----------------------------------------- select
// 注解:go语言提供了一个关键字 select,通过 select 可以监听 channel 上的数据流动
// 语法:(类似 switch)
select {
case <-chan:
// 如果channel 成功读到数据,则进入 case 块语句
case chan<- :
// 如果channel 成功写到数据,则进入 case 块语句
default:
// 如果上面都没有成功,则进入default处理流程
// 注意:慎用,很消耗 cpu
}
C#/JAVA 程序员转GO/GOLANG程序员笔记大全(DAY 06)的更多相关文章
-
C#/JAVA 程序员转GO/GOLANG程序员笔记大全(DAY 05)
----------------------------------------- error 使用 (异常处理) // 语法 (普通错误) import "errors" fun ...
-
C#/Java 程序员转GO/golang程序员笔记大全(day 01)
前言: 整理一下学习 Go 语言的笔记,作为一名老程序,学习一名新的开发语言自然不需要像小白那样从 HelloWorld 看起. 简单整理一下 Go 的一些差异处,希望对大家学习 go 有点帮助,不正 ...
-
C#/JAVA 程序员转GO/GOLANG程序员笔记大全(DAY 00)
一.安装说明 https://studygolang.com/dl 二.环境变量 // 下载 *.msi 安装文件,部分环境变量默认配置好了. 其他配置如下描述 三.目录及项目层级关系 在系统环境变量 ...
-
C#/JAVA 程序员转GO/GOLANG程序员笔记大全(DAY 04)
-------------------- interface 接口 // 定义: type IHumaner interface { SayHi() // 接口中只能是方法声明,没有实现,没有数据字段 ...
-
C#/JAVA 程序员转GO/GOLANG程序员笔记大全(DAY 03)
go语言当中,没有 class 的概念,那么面向对象的编程思想如何展现呢,go语言中对结构体的使用 struct. package main import "fmt" type P ...
-
C#/JAVA 程序员转GO/GOLANG程序员笔记大全(DAY 02)
------------------- 指针 go 保留的 c 语言指针的操作,同时增加了自动垃圾回收机制 var a = new(int) *a = // &a 内存地址 --------- ...
-
PHP笔记——java程序员看懂PHP程序
PHP笔记——java程序员看懂PHP程序 php是一种服务器端脚本语言,类型松散的语言. <?php ?> xml风格 <script language=”ph ...
-
使用 Java 开发兼容 IPv6 的网络应用程序
根据现有 IPv4 地址的部署速度,剩余的地址将在 10 到 20 年被使用殆尽.因此网络逐渐从 IPv4 向 IPv6 转换是不可避免的,相应的各种网络应用程序都将支持 IPv6.对于 Java,从 ...
-
*程序员推荐:每个程序员都应读的30本书
“如果能时光倒流,回到过去,作为一个开发人员,你可以告诉自己在职业生涯初期应该读一本,你会选择哪本书呢?我希望这个书单列表内容丰富,可以涵盖很多东西.” 很多程序员响应,他们在推荐时也写下自己的评语. ...
随机推荐
-
《Android深度探索HAL与驱动开发》第一章阅读心得
首先了解到Android系统架构是由四层构成:其中第一层是Linux内核,他的作用是负责Linux的驱动程序以及内存.进程.电源等管理操作:第二层是C/C++代码库,也就是Linux下.so的文件:第 ...
-
java之框架
框架有哪些?C++语言的QT.MFC.gtk,Java语言的SSH,php语言的 smarty(MVC模式),python语言的django(MTV模式)等等设计模式有哪些?工厂模式.适配器模式.策略 ...
-
.NET正则基础之——平衡组
1 概述 平衡组是微软在.NET中提出的一个概念,主要是结合几种正则语法规则,提供对配对出现的嵌套结构的匹配..NET是目前对正则支持最完备.功能最强大的语言平台之一,而平衡组正是其强大 ...
-
js下拉菜单默认值为当前年份,下拉菜单的选项为当前年份往前推5年
1:在jsp或者HTML页面中新建一个下拉框 年度:<select id="cx_nd" name="cx_nd" style="width: ...
-
PowerManager.WakeLock
PowerManager.WakeLock PowerManager.WakerLock是我分析Standup Timer源代码时发现的一个小知识点,Standup Timer 用WakeLock保证 ...
-
风萧萧兮易水寒 coding一去兮不复还
这一年都在忙碌中渡过.没有看过日落没有享受过日常.希望可以在忙碌中有些收获.工作马上要三年了. 风萧萧兮易水寒 coding一去兮不复还 记的刚毕业的时候喜欢自己晚上更新下博客.那时候也很忙.但是后来 ...
-
mysql基础-- 一条请求执行多条SQL语句
最近做一个数据库初始化工具的时候发现了这个问题,就是在一个Statement中执行一条SQL语句的时候可以正确执行,如果同时执行多条,就会报SQL语法错误,伤透了脑筋. 经过网上查找,发现有两种解决办 ...
-
使用FSharp 探索Dotnet图像处理功能1--反色变化
坚持写博客是最近的目标.加油. 业余学习fsharp以来一直觉得这才是Dotnet开发,或者说所有开发者应该拥有的语言.配合Visual Studio的代码提示,即时执行窗口.开发程序有着极大的乐趣. ...
-
ABP入门系列(6)——定义导航菜单
ABP入门系列目录--学习Abp框架之实操演练 完成了增删改查以及页面展示,这一节我们来为任务清单添加[导航菜单]. 在以往的项目中,大家可能会手动在layout页面中添加一个a标签来新增导航菜单,这 ...
-
ItunesConnect:";Missing Push Notification Entitlement";警告-----以及解决方法
最近开发的cordova应用,要做ios的适配,并且发布版本,但是有一次在发测试版本的时候,突然收到一封邮件警告,原文如下: Missing Push Notification Entitlement ...