初识golang，这部分也不是很了解，百度了一下，做个小记录goroutine是golang用来做并发处理的，使用起来很简单 go func(){...}()，就是看起来随便用一般而容易go的滥用，所以使用时要仔细斟酌才好。channel 大约是用来在线程间传递数据的，主线程开通一个channel，...
分类：
其他好文 时间：
2015-03-04 14:32:48
阅读次数：
163
我们可以使用Channel来同步不同goroutines的执行。看下面的代码：package main import "fmt"import "time" //这个函数会在新的goroutine中运行，执行结束时会给done channel中传入值true//注意到中间有sleep了一秒func w...
分类：
其他好文 时间：
2015-03-04 11:01:13
阅读次数：
157
flume作为日志收集端，其本质上也是一个生产者消费者结构，source作为消息的producer，sink作为消息的consumer，中间的channel作消息的存储为了保证消息消费的正确性，flume使用了事务的机制，主要涉及的类：1）org.apache.flume.Transaction接口类，为访问channel提供事务的功..
分类：
Web程序 时间：
2015-03-04 06:22:18
阅读次数：
282
对于flume的监控，只需要监控channel的性能数据即可，source和sink的性能一部分可以从channel中表现出来。以MemoryChannel为例，在MemoryTransaction的构造函数中会实例化一个org.apache.flume.instrumentation.ChannelCounter对象publicMemoryTransaction(inttransCapacity,Ch..
分类：
Web程序 时间：
2015-03-04 06:22:07
阅读次数：
250
计时器用来定时执行任务，分享一段代码：package main import "time"import "fmt" func main() {//新建计时器，两秒以后触发，go触发计时器的方法比较特别，就是在计时器的channel中发送值timer1 := time.NewTimer(time.Se...
分类：
编程语言 时间：
2015-03-03 09:50:56
阅读次数：
147
[anaspace@buffer2~]$cat/proc/scsi/scsiAttacheddevices:Host:scsi0Channel:02Id:00Lun:00Vendor:DELLModel:PERCH710Rev:3.13Type:Direct-AccessANSISCSIrevision:05Host:scsi5Channel:00Id:00Lun:00Vendor:HL-DT-STModel:DVD-ROMDU90NRev:D300Type:CD-ROMANSISCSIrevision:05..
分类：
系统相关 时间：
2015-03-02 19:22:55
阅读次数：
422
%%% Vortex
%%% 漩涡效果
clc;
clear all;
close all;
addpath('E:\PhotoShop Algortihm\Image Processing\PS Algorithm');
I=imread('4.jpg');
Image=double(I);
[row, col,channel]=size(Image);
R=floor(max(row,...
分类：
其他好文 时间：
2015-03-02 13:07:33
阅读次数：
202
apache下一个版本(1.6)将会带来一个新的组件KafKaChannel，顾名思义就是使用kafka做channel，当然在CDH5.3版本已经存在这个channel。 大伙知道，常用的channel主要有三个： 1、memory channel：用内存做channel，优点是速度最快，...
分类：
Web程序 时间：
2015-03-01 19:38:20
阅读次数：
238
flume-ng 1.5 新增一个Spillable memory channel ：http://www.tuicool.com/articles/i2mUfqb虽然可以在sink阻塞时候，把event存入file channel，且file channel在flume崩溃再启动时能恢复数据，但是...
分类：
Web程序 时间：
2015-02-26 14:37:25
阅读次数：
261
