常见双通道channel使用： c2 := make(chan int, 2) c2 <- 1 c2 <- 2 c2 <- 3 fmt.Println(<-c2) fmt.Println(<-c2) fmt.Println(<-c2) 由于channel大小只有2个，在c2<-3那里一定会阻塞，然后程序一直阻塞下去死掉 程序报错：fatal error: all goroutines are asleep - deadlock! 改进方法：1、增大channel的大小 2、同步执行改成异步执行 （因为只有先执行c2<-3才能执行取<-c2数据） 所以以后如果有使用channel的大的场合，用池子进行公共管理要注意这些阻塞问题 c2 := make(chan int, 2) c2 <- 1 c...阅读全文
golang普通方法：package main import ( "fmt" ) func rand_generator_1() int { return rand.Int() } func main() { fmt.Println(rand_generator_1()) } golang生成器：package main import ( "fmt" "math/rand" ) /** * 生成器 * 根据已知权限使用函数生成相应数据，异步调用节省了大量时间。 * @author: niuyufu */ func rand_generator_1() int { return rand.Int() } //直接返回通道channel func rand_generator_2() chan ...阅读全文
简历投递：jobs@klook.com 地址：福田天安科技创业园A座 职位描述： 1. 负责Klook各线产品的开发、测试和上线 2. 负责管理自身项目和需求的优先级、按时高质量交付 职位要求： 1. 熟练掌握Golang语言，具有扎实的计算机基础和编程能力，熟悉常见的算法与数据结构 2. 熟悉Restful接口设计，有过互联网业务系统或相关技术产品开发经验 3. 有较强的工作责任心和良好的沟通协调能力，能在压力下独立解决问题 4. 熟练掌握MySQL数据库，擅长SQL优化者优先 5. 有熟悉一门静态（C/C++/Java）语言者优先 6. 开源贡献者优先，GitHub源码者优先，技术博客者优先 【 Klook客路团队 ...阅读全文
**DTLE是一个开源的数据传输中间件**，其针对的核心场景如下: **跨数据中心的数据传输**：DTLE能在数据中心间进行可靠数据传输，并提供链路压缩以降低传输成本 **云间数据同步/迁移**：DTLE能提供在公有云间架设数据同步通道，以支持数据容灾等需求 **数据汇聚**：DTLE能将多个数据源汇聚到同一个数据源，以提供数据分析/数据转储的功能 **数据订阅**：DTLE能将数据源的变更消息发往Kafka等消息中间件，以支持数据订阅通知/缓存失效通知等需求 **跨数据中心的双向复制**：DTLE能在数据中心间提供双向复制通道，以配合业务实现数据双写 **分布式架构**：DTLE在数据传输这个基本场景上，使用了成熟的分布式任务调度架构，可以便捷地在集群中配置大量的数据传...阅读全文
Docker今天宣布，聘请前Twitter首席财务官和Zynga财务主管Mike Gupta作为其新的首席财务官。Gupta自2012年12月以来担任twitter的首席财务官。去年7月升任高级副总裁负责战略投资。在此之前，他曾一度担任Twitter的公司财务副总裁并且在Zynga工作了大约一年半，值得注意的是他还在雅虎工作过8年。  Docker’s new CFO Mike Gupta Docker现任首席财务官Eric Bardin将成为Docker高级财务和业务操作的SVP。该公司表示，他将负责财务计划和分析，扩大D...阅读全文
早上刷牙，处于半睡状态。突然想起昨天晚上看到的那个 go-lang 的 MVC 框架，若使用 go func() 方式异步获取数据，应当是不错的。窃喜……梦醒…… 在地铁上被前前后后那些特种男女逼到车角，无奈。又想起早上那个白日梦，遂上网搜索了一番。得老赵的佳作一篇《F# 与ASP.NET（1）：基于事件的异步模式与异步Action》。之前看过，由于对微软无爱，未能细品。今日一读，如醍醐灌顶，豁然开朗。 遂整理思路如下，以待后用。 在说异步模型之前，先说说最常见的同步模型吧。例如下面的 PHP 代码： // 获取数据 $userInfo = getUserInfo(); $newsList = getNewsList(); $topRateNewsList = getNewsList('DE...阅读全文
package main import ( "fmt" ) var c = make(chan int) var str string func ready() { str = "abc" fmt.Println("ready1") <-c //get fmt.Println("ready2") } func main() { go ready() c <- 1 //put fmt.Println(str) } ready1 ready2//ready2在abc前 是因为调度，没有必然关系 abc 1.对于非缓冲通道： “从通道接收数据”的操作 一定会在 “向通道发送数据”的操作完成前发生。 2.对于缓冲通道： “向通道发送数据”的操作 一定会在 “从通道接收数据”的操作完成前发生...阅读全文
1.返回值使用通道 func main() { // 生成随机数作为一个服务 randService := randGenerator() // 从服务中读取随机数并打印 fmt.Printf("%d\n",<-randService) } func randGenerator() chan int { // 创建通道 out := make(chan int) // 创建协程 go func() { for { //向通道内写入数据，如果无人读取会等待 out <- rand.Int() } }() return out } 2.参数使用通道 //一个查询结构体 type query struct { //参数Channel sql chan string //结果Channel resu...阅读全文
package main import ( "fmt" ) func main() { var chan_test chan interface{} //双项通道 var read_test <-chan interface{} //单项通道 只支持 读 var write_test chan<- interface{} //单项通道 只支持 写 read_test <- "xiao" //会报错。因为这个通道 只是单项通道只支持读 不支持写 <-write_test //会报错。因为这个通道 只是单项通道只支持写 不支持读 fmt.Println(chan_test) fmt.Println(read_test) fmt.Println(write_test) ...阅读全文
为什么会出现死锁的问题？ fatal error: all goroutines are asleep - deadlock...阅读全文
作者：谢海滨 在 上篇文章 中我们介绍了 PingCAP Talent Plan - TiKV 方向的课程内容，本文将从课程设计的角度和大家聊一聊 TiDB 方向的课程内容，包括课程设计的逻辑，和课程学习过程中常见的问题及解答等。 TiDB 方向课程内容 TiDB 作为一个支持 MySQL 协议，以某种支持事务的分布式 KV 存储引擎为底层存储的 SQL 引擎，主要需要处理与 MySQL 客户端的交互，在底层存储引擎中存取数据，以及实现 SQL 功能。 在 Talent Plan 课程设计上，我们主要关注在如何实现 SQL 功能，并将重点放在如何实现 SQL 优化器以及执行引擎上： 优化器：主要负责生成并且优化查询计划，执行计划的好坏将极大影响执行效率，因此这一部分也可以说是整个 SQL 功...阅读全文
作者：谢海滨 在 上篇文章 中我们介绍了 PingCAP Talent Plan - TiKV 方向的课程内容，本文将从课程设计的角度和大家聊一聊 TiDB 方向的课程内容，包括课程设计的逻辑，和课程学习过程中常见的问题及解答等。 TiDB 方向课程内容 TiDB 作为一个支持 MySQL 协议，以某种支持事务的分布式 KV 存储引擎为底层存储的 SQL 引擎，主要需要处理与 MySQL 客户端的交互，在底层存储引擎中存取数据，以及实现 SQL 功能。 在 Talent Plan 课程设计上，我们主要关注在如何实现 SQL 功能，并将重点放在如何实现 SQL 优化器以及执行引擎上： 优化器：主要负责生成并且优化查询计划，执行计划的好坏将极大影响执行效率，因此这一部分也可以说是整个 SQL 功...阅读全文
tick := time.Tick(1 * time.second)表示每隔一段生产一条数据到tick通道中。boom := time.After(500 * time.Millisecond)表示在一段时间之后产生一条数据到tick通道中，不会持续产生。func timetick() { tick := time.Tick(100 * time.Millisecond) boom := time.After(500 * time.Millisecond) for { select { case <-tick: fmt.Println("tick.") case <-boom: fmt.Println("BOOM!") return default: fmt.Println(" .") ti...阅读全文
最近在学习Go语言，学了有一个月时间，从微信公众号“码洞”上看到了快学系列教材，很棒的文章。最新的一篇是讲通道，里面提到了多路复用channel，但是没有讲在多路复用中，如何优雅的关闭通道，我在这里做了一些尝试，发出来供交流。《快学 Go 语言》第 12 课 —— 神秘的地下通道 的访问地址如下，先阅读：https://mp.weixin.qq.com/s/eZTFa-8drmkZUXsvHycorQ然后是下面是我增加通道关闭后的代码，详见注释：package main import ( "fmt" "time" ) func send(ch chan int, gap time.Duration) { //每个通道模拟发送5个消息就结束 for i := 0;i<5;i++{ //i++ ...阅读全文
不同的并行协程之间交流的方式有两种，一种是通过共享变量，另一种是通过队列。Go 语言鼓励使用队列的形式来交流，它单独为协程之间的队列数据交流定制了特殊的语法 —— 通道。通道是协程的输入和输出。作为协程的输出，通道是一个容器，它可以容纳数据。作为协程的输入，通道是一个生产者，它可以向协程提供数据。通道作为容器是有限定大小的，满了就写不进去，空了就读不出来。通道还有它自己的类型，它可以限定进入通道的数据的类型。图片创建通道创建通道只有一种语法，那就是 make 全局函数，提供第一个类型参数限定通道可以容纳的数据类型，再提供第二个整数参数作为通道的容器大小。大小参数是可选的，如果不填，那这个通道的容量为零，叫着「非缓冲型通道」，非缓冲型通道必须确保有协程正在尝试读取当前通道，否则写操作就会阻塞直...阅读全文
