前面的几篇文章介绍了一些ZooKeeper的应用方法， 本文将介绍Curator访问ZooKeeper的一些基本方法， 而不仅仅限于指定的Recipes， 你可以使用Curator API任意的访问ZooKeeper。
Curator框架提供了一套高级的API， 简化了ZooKeeper的操作。 它增加了很多使用ZooKeeper开发的特性，可以处理ZooKeeper集群复杂的连接管理和重试机制。 这些特性包括：
使用Curator也可以简化Ephemeral Node (临时节点)的操作。 临时节点驻存在ZooKeeper中，当连接和session断掉时被删除。
比如通过ZooKeeper发布服务，服务启动时将自己的信息注册为临时节点，当服务断掉时ZooKeeper将此临时节点删除，这样client就不会得到服务的信息了。
原文链接 作者: Mark Needham 译者: 李璟(jlee381344197@gmail.com)
最近我们想构建一个需要使用外部依赖进行计算的域对象，同时我们希望在测试的时候能够忽略这些依赖。
可以利用ZooKeeper在集群的各个节点之间缓存数据。 每个节点都可以得到最新的缓存的数据。 Curator提供了三种类型的缓存方式：Path Cache,Node Cache 和Tree Cache。
Path Cache用来监控一个ZNode的子节点. 当一个子节点增加， 更新，删除时， Path Cache会改变它的状态， 会包含最新的子节点， 子节点的数据和状态。 这也正如它的名字表示的那样， 那监控path。
实际使用时会涉及到四个类：
原文链接 作者: Cyrille Martraire 译者: 李璟(jlee381344197@gmail.com)
在函数式编程中，Map和Fold是两个非常有用的操作，它们存在于每一个函数式编程语言中。既然Map和Fold操作如此强大和重要，但是Java语言缺乏Map和Fold机制，那么该如何解释我们使用Java完成日常编码工作呢？实际上你已经在Java中利用手动编写循环的方式实现了Map和Fold操作（译者注：许多动态语言如python都提供了内置的实现）。
免责声明：本篇文章仅仅只是一篇入门简介，并非函数式编程的参考。函数式编程爱好者可能会不赞同本文观点。
这一篇文章我们将学习使用Curator来实现计数器。 顾名思义，计数器是用来计数的, 利用ZooKeeper可以实现一个集群共享的计数器。 只要使用相同的path就可以得到最新的计数器值， 这是由ZooKeeper的一致性保证的。Curator有两个计数器， 一个是用int来计数，一个用long来计数。
这个类使用int类型来计数。 主要涉及三个类。
SharedCount代表计数器， 可以为它增加一个SharedCountListener，当计数器改变时此Listener可以监听到改变的事件，而SharedCountReader可以读取到最新的值， 包括字面值和带版本信息的值VersionedValue。
分布式的锁全局同步， 这意味着任何一个时间点不会有两个客户端都拥有相同的锁。
首先我们先看一个全局可重入的锁。 Shared意味着锁是全局可见的， 客户端都可以请求锁。 Reentrant和JDK的ReentrantLock类似， 意味着同一个客户端在拥有锁的同时，可以多次获取，不会被阻塞。 它是由类InterProcessMutex来实现。 它的构造函数为：
(8 votes, average: 4.75 out of 5)
Loading...public InterProcessMutex(CuratorFramework client, String path)
原文链接 原文作者：Dani Buiza 译者：Toien Liu 校对：深海
编者的话：注解是java的一个主要特性且每个java开发者都应该知道如何使用它。
我们已经在Java Code Geeks提供了丰富的教程, 如Creating Your Own Java Annotations, Java Annotations Tutorial with Custom Annotation 和 Java Annotations: Explored & Explained.
我们也有些文章是关于注解在不同类库中的应用，包括 Make your Spring Security @Secured annotations more DRY和 Java Annotations & A Real World Spring Example.
现在，是时候汇总这些和注解相关的信息到一篇文章了，祝大家阅读愉快。 阅读全文
声明：本文是《C#并发编程经典实例》的样章，感谢图灵授权并发编程网站发布样章，禁止以任何形式转载此文。
问题
我们希望事件能在预定的时间内到达，即使事件不到达，也要确保程序能及时进行响应。
通常此类事件是单一的异步操作（例如，等待 Web 服务请求的响应）。
解决方案
Timeout 操 作 符 在 输 入 流 上 建 立 一 个 可 调 节 的 超 时 窗 口。 一 旦 新 的 事 件 到 达， 就 重 置 超 时 窗 口。 如 果 超 过 期 限 后 事 件 仍 没 到 达，Timeout 操 作 符 就 结 束 流， 并 产 生 一 个 包 含 TimeoutException 的 OnError 通知。
声明：本文是《C#并发编程经典实例》的样章，感谢图灵授权并发编程网站发布样章，禁止以任何形式转载此文。
问题
有时事件来得太快，这是编写响应式代码时经常碰到的问题。一个速度太快的事件流可导
致程序的处理过程崩溃。
解决方案
Rx 专门提供了几个操作符，用来对付大量涌现的事件数据。Throttle 和 Sample 这两个操 作符提供了两种不同方法来抑制快速涌来的输入事件。
声明：本文是《C#并发编程经典实例》的样章，感谢图灵授权并发编程网站发布样章，禁止以任何形式转载此文。
问题
有一系列事件，需要在它们到达时进行分组。举个例子，需要对一些成对的输入作出响
应。第二个例子，需要在 2 秒钟的窗口期内，对所有输入进行响应。
声明：本文是《C#并发编程经典实例》的样章，感谢图灵授权并发编程网站发布样章，禁止以任何形式转载此文。
问题
Rx 尽量做到了线程不可知（thread agnostic）。因此它会在任意一个活动线程中发出通知（例如 OnNext）。
但是我们通常希望通知只发给特定的上下文。例如 UI 元素只能被它所属的 UI 线程控制， 因此，如果要根据 Rx 的通知来修改 UI，就应该把通知“转移”到 UI 线程。
声明：本文是《C#并发编程经典实例》的样章，感谢图灵授权并发编程网站发布样章，禁止以任何形式转载此文。
问题
把一个事件作为 Rx 输入流，每次事件发生时通过 OnNext 生成数据。
解决方案
Observable 类 定 义 了 一 些 事 件 转 换 器。 大 部 分 .NET 框 架 事 件 与 FromEventPattern 兼 容， 对于不遵循通用模式的事件，需要改用 FromEvent。
FromEventPattern 最适合使用委托类型为 EventHandler 的事件。很多较新框架类的事 件都采用了这种委托类型。例如，Progress 类定义了事件 ProgressChanged，这个事件 的委托类型就是 EventHandler，因此，它就很容易被封装到 FromEventPattern：
(6 votes, average: 4.17 out of 5)