Guava文档翻译之 Service

概览

Guava的接口代表了一个有运行状态的对象,有启动和停止的方法。比如网络服务器,RPC服务器,以及计时器等,都可以实现Service接口。掌管像这样的服务的状态,需要正确地管理启动和关闭,因此会是繁琐的,特别是牵扯到多线程和调度。Guava提供了一个基本的骨架,可以帮你管理状态逻辑,以及同步的细节

一个Service的通常的生命周期是

一个已经停止的Service是不能被重启的。如果这个服务在启动或者运行、停止时失败,那么它会转入Service.State.FAILED状态。

一个服务可以被使用 startAsync()来异步地启动,这个方法会返回‘this‘引用,以方便地使用方法链。只有这个服务是NEW状态的时候才能调用。所以,你的程序应该有个唯一的地方来启动每一个服务。

停止服务是类似的,使用异步的stopAsync()方法。但是不像startAsync()方法,它可以安全地调用多次。这使得可以它可以应对在关闭服务器可能遇到的竞争问题。

服务也提供了几种方法来等待服务状态转换的完成。

  • 异步地使用addListener()。addListener()允许你添加一个Service.Listener,它会在服务的服务状态转换时被调用。需要注意的是,如果在这个listener被添加时,服务器已经不是NEW的状态。,那么已经发生过的状态转换是不会在这个listener上重放。
  • 异步地使用awaitRunning()。它是不可中断的(uniterruptible),不会抛出受检异常,会在服务启动完毕时返回。如果服务启动失败,会抛出一个IllegalStateException。类似的是 awaitTerminated(),调用它等待服务到达终止状态(TERMINATED or FAILED)。这两个方法都有重载的方法,允许指定超时时间。

Service接口是微妙的。我们不建议直接实现它。你可以使用我们在guava提供几个虚类中的一个作为你的实现的基础。每个基类提供了一个特定的线程模型。

实现

AbstractIdleService

AbstractIdleService骨架实现了一个Service,这个服务不需要在“running”状态执行任何动作,因此它在运行时也不需要一个线程,但是它仍然需要执行启动和停止的动作。实现这样的服务只需要继承AbstractIdleService,并且实现 startUp()以及shutDown()方法,

protected void startUp() {
  servlets.add(new GcStatsServlet());
}
protected void shutDown() {}

需要指出的是,任何对GcStatsServlet的查询已经运行于一个线程中了。因此,在这个服务运行时,我们不需要它执行任务操作。

AbstractExecutionThreadService

一个AbstractExecutionThreadService在同一个线程中执行启动,动行和关闭操作。你必须重写run() 方法,而且这个方法必须对关闭请求作为响应。比如,你或许会在一个工作循环中执行这些动作:

public void run() {
  while (isRunning()) {
    // perform a unit of work
  }
}

或者,你可以覆盖 triggerShutdown()方法,只要它能够使得run()方法返回。覆盖startUp()和shutdown()方法是可选的,但是服务的状态会由这个骨架替你管理。

protected void startUp() {
  dispatcher.listenForConnections(port, queue);
}
protected void run() {
  Connection connection;
  while ((connection = queue.take() != POISON)) {
    process(connection);
  }
}
protected void triggerShutdown() {
  dispatcher.stopListeningForConnections(queue);
  queue.put(POISON);
}

需要注意的是start()调用了你的startUp()方法,为你创建了一个线程,并且在这个线程中调用run()方法。stop()方法调用了triggerShutdown()方法,并且等待线程停止。(译注:重点是run()方法不是在调用start()的线程中执行的)

AbstractScheduledService

一个AbstractScheduledService在它动行时执行一些周期性的任务。它的子类覆盖runOneIteration()来指定每个周期的任务,同时也需要覆盖我们熟悉的startUp和shutDown() 方法

为了描述怎么调度执行,你需要实现scheduler()方法。通常而言,你会使用已经AbstractScheduledService.Scheduler提供的几个调度器中的一个,newFixedRateSchedule(initialDelay, delay, TimeUnit)或者newFixedDelaySchedule(initialDelay, delay, TimeUnit),与我们熟知的ScheduledExecutorService中的方法相类。自定义的调度器可以用来实现,请参见Javadoc.

AbstractService

如果你需要自己管理线程,就需要直接覆盖AbstractService。通常来说,以上提到的几种实现就够用了,但是,有些情况下是建议实现AbstractService的,比如,你对有自己的线程语义的东西进行建模,把它做成一个Service,你就会有自己特殊的线程相关的需求。

为了实现AbstractService,你需要实现这两个方法

  • doStart():doStart()在第一次调用startAsync()时被直接调用,你的doStart()方法应该完成所有初始化工作,并且在启动成功时调用,或者启动失败时调用。
  • doStop():doStop()在第一次调用stopAsync()时被调用,你的doStop()方法应该关闭你的服务,并且如果关闭成功,最终调用notifyStopped(),或者关闭失败,就调用notifyFailed()

你的doStart和doStop方法应该执行得很快。如果你需要进行昂贵的初始化工作,比如读取文件,开启网络连接,或者进行任何可能会阻塞的工作,你需要移动这些工作到另一个线程去做。

使用SerivceManager

在Service的骨架实现之外,Guava还提供了一个ServiceManager类,它使得一些跟多个Service的实现相关操作操作更简单一些。使用Service的集合创建一个新的ServiceManager。然后你就可以管理它们了:

或者检查这些服务:

  • isHealthy() 在所有服务都在状态时返回true
  • 将会返回一个所有服务的一致的snapshot,以它们的状态作为索引。
  • startupTimes()将会返回从受管理的Service到它花了多少毫秒启动的map.Guava保证这个返回的map将按照启动时间(startup time)排序。

别然我们建议服务的生命周期通过ServiceManager来管理,但是通过其它机制进行的状态转换不会影响它的方法的正确性。比如,如果一些服务不是通过startAsync()启动的,监听器仍然会在合适的时机被调用,并且 awaitHealthy()也会照常工作。ServiceManager的唯一要求是在ServiceManager构造时,所有的Serivce都在NEW状态。

时间: 2025-01-07 11:02:14

Guava文档翻译之 Service的相关文章

Guava文档翻译之ListenableFuture

ListenableFutureExplained 并发是一个困难的问题,但是使用强大而简单的抽象可以极大地简化并发问题.为了简化事情,Guava使用ListenableFuture继承了JDK的Future接口. 我们强烈建议你在所在代码里总是使用ListenableFuture,而不是Future,因为: 大多数Future相关的接口需要它 这比以后换成ListenableFuture更容易 工具的提供者不需要为它们的方法分别提供Future和ListenableFuture的变体 接口 I

Guava文档翻译之 Guava简介

用户指南 User Guide Guava项目包括了一些Google的核心库,是我们在基于Java的项目中所依赖的,这些库包括:集合,缓存,对基本类型的支持,并发库,通用的注解,字符串处理,I/O,等等.这些工具的每一个真的都在被Google每天使用着,而且是在生产系统中. 但是只是在Javadoc中寻觅不是学会怎么使用一个库的最有效的方法.在此,我们试图对Guava的一些最流行和强大的特性做出良好的阐述. 这个wiki还没有完工,它的有些部分仍然在构建中. 基础工具:让使用Java这个语言更令

Spring Cloud ZooKeeper集成Feign的坑2,服务调用了一次后第二次调用就变成了500,错误:Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is com.n

错误如下: 2017-09-19 15:05:24.659 INFO 9986 --- [ main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.spring[email protected]56528192: startup date [Tue Sep 19 15:05:24 CST 2017]; root of context hierarchy 2017-09-19 15:05:24.858 INFO 9986 --

开源介绍:Google Guava、Google Guice、Joda-Time

一.Guava 是一个 Google 的基于java1.6的类库集合的扩展项目,包括 collections, caching, primitives support, concurrency libraries, common annotations, string processing, I/O, 等等. 这些高质量的 API 可以使你的JAVa代码更加优雅,更加简洁,让你工作更加轻松愉悦.下面我们就开启优雅Java编程学习之旅! 项目相关信息: 官方首页:http://code.googl

Guava: 事件总线EventBus

EventBus 直译过来就是事件总线,它使用发布订阅模式支持组件之间的通信,不需要显式地注册回调,比观察者模式更灵活,可用于替换Java中传统的事件监听模式,EventBus的作用就是解耦,它不是通用的发布订阅系统,也不能用于进程间通信.可用于Android的EventBus库主要有这几个:Google出品的Guava,Guava是一个庞大的库,EventBus 只是它附带的一个小功能,因此实际项目中使用并不多.用的最多的是greenrobot/EventBus,这个库的优点是接口简洁,集成方

CloudStack中文文档翻译规范--不间断更新

目前CS中文文档翻译工作稳步进行中,但安装指南翻译完成后发现些许问题,大多为翻译规范问题,为了解决该问题,遂整理出CS中文文档翻译规范供各位翻译官查阅. 特殊格式翻译时注意事项: 进行CS文档翻译时,时常会在翻译时看到特殊格式的条目,以下表格按类型分类描述哪些特殊类型的格式该如何翻译. 类型 原文示例(翻译前) 正确格式示例(翻译后) 注意 字体加粗 **Path.** The exported path from the server. **路径.** 服务器输出的路径. **xxx** 必须

Android官方技术文档翻译——Gradle 插件用户指南(4)

近期赶项目,白天基本没时间,仅仅有晚上在家的时候才干看一看.昨天晚上仅仅翻译完了第四章,今天就仅仅发第四章吧. 本文译自Android官方技术文档<Gradle Plugin User Guide>,原文地址:http://tools.android.com/tech-docs/new-build-system/user-guide. 翻译不易.转载请注明CSDN博客上的出处: http://blog.csdn.net/maosidiaoxian/article/details/4195580

Google Guava教程

Google Guava官方教程(中文版) 原文链接  译文链接 译者: 沈义扬,罗立树,何一昕,武祖  校对:方腾飞 引言 Guava工程包含了若干被Google的 Java项目广泛依赖 的核心库,例如:集合 [collections] .缓存 [caching] .原生类型支持 [primitives support] .并发库 [concurrency libraries] .通用注解 [common annotations] .字符串处理 [string processing] .I/O

Oracle 12c 12.1.0.1.0管理控制文件官方文档翻译说明

Link: http://download.csdn.net/detail/rlhua/7718571 官方Link: http://docs.oracle.com/database/121/ADMIN/control.htm#ADMIN006 版本: [email protected]>select * from v$version; BANNER