一、Kafka消费者编程模型 1.分区消费模型 分区消费伪代码描述 main() 获取分区的size for index =0 to size create thread(or process) consumer(Index) 第index个线程(进程) consumer(index) 创建到kaf ...
分类:
其他好文 时间:
2018-10-09 23:57:46
阅读次数:
330
递归,英文为Recursion, 在计算机科学中,递归指得是在函数的定义中使用函数自身。
递归,包含了两个意思:递 和 归。递是只传递下去,归是指归来,也就是说,递归有去也有回。
分类:
其他好文 时间:
2018-10-09 16:14:46
阅读次数:
233
基本概念 1.并发编程模型 线程之间的通信机制有两种:共享内存和消息传递。Java的并发采用的是隐式的共享内存模型。 Java内存模型(JMM)是围绕着在并发过程中如何处理原子性、可见性和有序性来建立的。 原子性:基本数据类型的访问读写是具备原子性的(针对long和double有非原子性协定),sy ...
分类:
编程语言 时间:
2018-10-04 11:45:42
阅读次数:
156
Rod Johnson编写 目标:使J2EE开发变得更加容易,通过启用基于 POJO 编程模型来促进良好的编程实践。 依赖注入(DI) 面向方面的程序设计(AOP): 常用注入方式 1. 设值注入(自动调用java类的set方法) 2. 构造注入(调用java类的构造方法) Bean id Clas ...
分类:
编程语言 时间:
2018-09-28 22:39:24
阅读次数:
209
1.前言 *.NET Framework提供了执行异步操作的三种模式: 异步编程模型(APM)模式(也称为IAsyncResult的模式),其中异步操作要求Begin和End方法(例如,BeginWrite和EndWrite异步写入操作)。这种模式不再被推荐用于新开发。有关更多信息,请参阅异步编程模 ...
//本篇为转贴 本系列里完成端口的代码在两年前就已经写好了,但是由于许久没有写东西了,不知该如何提笔,所以这篇文档总是在酝酿之中……酝酿了两年之后,终于决定开始动笔了,但愿还不算晚….. 这篇文档我非常详细并且图文并茂的介绍了关于网络编程模型中完成端口的方方面面的信息,从API的用法到使用的步骤,从 ...
本章大致分为4部分: Java内存模型的基础 并发编程模型的两个关键问题 在并发编程中,需要处理两个关键问题: 线程之间如何通信:指线程之间以何种机制来交换信息。在命令式编程中,线程之间的通信机制有两种(共享内存和消息传递) 在共享内存的并发模型里,线程之间共享程序的公共状态,通过写-读内存中的公共 ...
分类:
编程语言 时间:
2018-09-23 18:20:52
阅读次数:
228
1、spring是如何管理事务的? Spring并不是直接管理事务,而是提供了多种事务管理器,他们将事务管理的职责委托给持久化机制所提供的相关平台框架的事务来实现,spring为不同的事务API提供一致的编程模型。 Spring的事务分为编程式事务和声明式事务,编程式事务允许用户在代码中精确定义事务 ...
分类:
编程语言 时间:
2018-09-16 20:54:34
阅读次数:
285
1.MapReduce编程模型概述 MapReduce编程模型给出了分布式的编程方法,总共分为5个步骤。分为这5个步骤的优点:组件化和并行化 (1)迭代。遍历输入数据,并将其解析成key/value键值对 (2)将输入的key/value对映射(map)成另外一些key/value对 (3)依据ke ...
分类:
其他好文 时间:
2018-09-15 14:35:05
阅读次数:
168
初识RDD 什么是RDD? 定义:Resilient distributed datasets (RDD), an efficient, general-purpose and fault-tolerant abstraction for sharing data in cluster applic ...
分类:
其他好文 时间:
2018-09-13 17:30:39
阅读次数:
174