1. 计算阶乘 package main import ( "fmt" _ "time" "sync" ) //需求:现在要计算 1-200 的各个数的阶乘,并且把各个数的阶乘放入到map中。 //最后显示出来。要求使用goroutine完成 //思路 //1. 编写一个函数,来计算各个数的阶乘,并 ...
分类:
其他好文 时间:
2020-01-27 09:25:24
阅读次数:
108
1. 案例1 package main import ( "fmt" _ "time" ) //write Data func writeData(intChan chan int) { for i := 1; i <= 50; i++ { //放入数据 intChan <- i // fmt.Pr ...
分类:
其他好文 时间:
2020-01-27 09:17:19
阅读次数:
64
"概要" "goroutine 的控制" "取消控制" "超时控制" "goroutine 之间的传值" "总结" 概要 golang 的提供的 channel 机制是基于 CSP(Communicating Sequencial Processes)模型的并发模式. 通过 channel, 可以很 ...
分类:
其他好文 时间:
2020-01-26 19:20:54
阅读次数:
72
flume agent 内部原理 1、Source采集数据,将数据封装成Event对象,然后将数据交给 Channel Processor (利用该类的方法进行下一步的处理) 2、 Channel Processor 将Event事件传递给拦截器链(Intercepter,进行简单的数据清洗),然后 ...
分类:
Web程序 时间:
2020-01-26 14:29:01
阅读次数:
130
CSP并发模型 CSP模型是上个世纪七十年代提出的,用于描述两个独立的并发实体通过共享的通讯 channel(管道)进行通信的并发模型。 CSP中channel是第一类对象,它不关注发送消息的实体,而关注与发送消息时使用的channel。 Golang CSP Golang 就是借用CSP模型的一些 ...
分类:
其他好文 时间:
2020-01-26 00:52:03
阅读次数:
122
先给出答案: 需要结合具体使用的source、channel和sink来分析,具体结果可看本文最后一节。 Flume事务 ====================== 一提到事务,我们首先就想到的是MySQL中的事务, 事务就是将一批操作做成原子性的 ,即这一批要么都成功,要么都失败。 同样的道理, ...
分类:
Web程序 时间:
2020-01-24 00:14:47
阅读次数:
972
目录 一、背景 二、Flume的简介 三、Flume NG的介绍 3.1 Flume特点 3.2 Flume的一些核心概念 3.3 Flume NG的体系结构 3.4 Source 3.5 Channel 3.6 Sink 四、Flume的部署类型 4.1 单一流程 4.2 多代理流程(多个agen ...
分类:
Web程序 时间:
2020-01-22 10:51:06
阅读次数:
131
jvm调优实战 前端时间把公司的一个分布式定时调度的系统弄上了容器云,部署在kubernetes,在容器运行的动不动就出现问题,特别容易jvm溢出,导致程序不可用,终端无法进入,日志一直在刷错误,kubernetes也没有将该容器自动重启。业务方基本每天都在反馈task不稳定,后续就协助接手看了下, ...
分类:
其他好文 时间:
2020-01-21 10:58:05
阅读次数:
97
Most basic operations in Go are not synchronized. In other words, they are not concurrency-safe. https://go101.org/article/channel.html ...
分类:
其他好文 时间:
2020-01-21 00:20:08
阅读次数:
94
在Go语言中,有一种特殊的struct{}类型的channel,它不能被写入任何数据,只有通过close()函数进行关闭操作,才能进行输出操作。。struct类型的channel不占用任何内存!!! https://blog.csdn.net/qq_35976351/article/details/ ...
分类:
编程语言 时间:
2020-01-20 15:10:03
阅读次数:
89