var optimizeCb = function(func, context, argCount) { if (context void 0) { return func; } switch (argCount == null ? 3 : argCount) { case 1: return fu ...
分类:
其他好文 时间:
2017-09-05 23:02:46
阅读次数:
187
与Topic相关的代码主要位于nsqd/nsqd.go, nsqd/topic.go中。Topic的获取Topic通过GetTopic函数获取GetTopic函数用于获取topic对象,首先先尝试从topicMap表中获取,如果指定的topic存在,则直接返回topic对象。当topic不存在时需要... ...
分类:
其他好文 时间:
2017-08-31 12:55:24
阅读次数:
147
配置解析nsqd的主函数位于apps/nsqd.go中的main函数首先main函数调用nsqFlagset和Parse进行命令行参数集初始化, 然后判断version参数是否存在,若存在,则打印版本号并退出程序接下来钩住系统的syscall.SIGINT和syscall.SIGTERM消息,用来阻... ...
分类:
其他好文 时间:
2017-08-31 12:43:39
阅读次数:
152
diskQueue是backendQueue接口的一个实现。backendQueue的作用是在实现在内存go channel缓冲区满的情况下对消息的处理的对象。 除了diskQueue外还有dummyBackendQueue实现了backendQueue接口。对于临时(#ephemeral结尾)To... ...
分类:
其他好文 时间:
2017-08-31 12:42:10
阅读次数:
265
与Channel相关的代码主要位于nsqd/channel.go, nsqd/nsqd.go中。Channel与Topic的关系Channel是消费者订阅特定Topic的一种抽象。对于发往Topic的消息,nsqd向该Topic下的所有Channel投递消息,而同一个Channel只投递一次,Cha... ...
分类:
其他好文 时间:
2017-08-31 12:38:06
阅读次数:
239
转自:http://blog.csdn.net/longlong2015/article/details/48174421 http://blog.csdn.net/mra__s__/article/details/55517204 JDK 1.7源码阅读笔记(三)集合类之LinkedList 转自 ...
分类:
其他好文 时间:
2017-08-21 22:56:25
阅读次数:
336
1、定时回调 每个飞控平台都提供一个1khz的定时器,通过“注册”一个定时器来获取1khz的定时功能。所有注册的定时器将被顺序调用。调用形式: hal.scheduler->register_timer_process((AP_HAL::MemberProc)(&AP_Baro_MS5611::_u ...
分类:
编程语言 时间:
2017-06-06 22:14:27
阅读次数:
172
初始化过程中四个数据成员中的两个数据成员被初始化: 一、vc被初始化为STP提供的C调用接口函数vc_createValidityChecker(); 二、optimizeDivides被初始化为false 重点探讨另外两个数据成员。 一、ExprHashMap constructed ExprHa ...
分类:
其他好文 时间:
2017-05-29 19:12:17
阅读次数:
228
Overview source采集的日志首先会传入ChannelProcessor, 在其内首先会通过Interceptors进行过滤加工,然后通过ChannelSelector选择channel。 Source和Sink之间是异步的,sink只需要监听自己关系的Channel的变化即可。 sink ...
分类:
Web程序 时间:
2017-05-18 15:47:19
阅读次数:
400
项目中使用了vue,一直在比较computed和$watch的使用场景,今天周末抽时间看了下vue中$watch的源码部分,也查阅了一些别人的文章,暂时把自己的笔记记录于此,供以后查阅: 实现一个简单的$watch: 1 const v = new Vue({ 2 data:{ 3 a: 1, 4 ...
分类:
其他好文 时间:
2017-05-16 13:01:55
阅读次数:
238