org.jclouds.concurrent.config

Class ExecutorServiceModule

java.lang.Object

com.google.inject.AbstractModule

org.jclouds.concurrent.config.ExecutorServiceModule

All Implemented Interfaces:

com.google.inject.Module

Direct Known Subclasses:

EnterpriseConfigurationModule

public class ExecutorServiceModule
extends com.google.inject.AbstractModule

Configures ListeningExecutorService. Note that this uses threads.

This extends the underlying Future to expose a description (the task's toString) and the submission context (stack trace). The submission stack trace is appended to relevant stack traces on exceptions that are returned, so the user can see the logical chain of execution (in the executor, and where it was passed to the executor).

Constructor Summary

Constructors

Constructor and Description
ExecutorServiceModule()
ExecutorServiceModule(ExecutorService userExecutor)
ExecutorServiceModule(ExecutorService userExecutor, ExecutorService ioExecutor) Deprecated. ioExecutor is no longer used. This constructor will be removed in jclouds v2. Use ExecutorServiceModule(ExecutorService) instead.
ExecutorServiceModule(com.google.common.util.concurrent.ListeningExecutorService userExecutor)
ExecutorServiceModule(com.google.common.util.concurrent.ListeningExecutorService userExecutor, com.google.common.util.concurrent.ListeningExecutorService ioExecutor) Deprecated. ioExecutor is no longer used. This constructor will be removed in jclouds v2. Use ExecutorServiceModule(ListeningExecutorService) instead.

Method Summary

Modifier and Type	Method and Description
protected void	configure()
static com.google.common.util.concurrent.SimpleTimeLimiter	createSimpleTimeLimiter(ExecutorService executorService) Reflective creation of SimpleTimeLimiter to allow compatibility with Guava 23.0.

Methods inherited from class com.google.inject.AbstractModule

addError, addError, addError, bind, bind, bind, bindConstant, binder, bindInterceptor, bindListener, bindScope, configure, convertToTypes, currentStage, getMembersInjector, getMembersInjector, getProvider, getProvider, install, requestInjection, requestStaticInjection, requireBinding, requireBinding

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExecutorServiceModule

public ExecutorServiceModule()

ExecutorServiceModule

@Deprecated
public ExecutorServiceModule(@Named(value="jclouds.user-threads")
                                         ExecutorService userExecutor,
                                         ExecutorService ioExecutor)

Deprecated. ioExecutor is no longer used. This constructor will be removed in jclouds v2. Use ExecutorServiceModule(ExecutorService) instead.

ExecutorServiceModule

@Deprecated
public ExecutorServiceModule(@Named(value="jclouds.user-threads")
                                         com.google.common.util.concurrent.ListeningExecutorService userExecutor,
                                         com.google.common.util.concurrent.ListeningExecutorService ioExecutor)

Deprecated. ioExecutor is no longer used. This constructor will be removed in jclouds v2. Use ExecutorServiceModule(ListeningExecutorService) instead.

ExecutorServiceModule

public ExecutorServiceModule(@Named(value="jclouds.user-threads")
                             ExecutorService userExecutor)

ExecutorServiceModule

public ExecutorServiceModule(@Named(value="jclouds.user-threads")
                             com.google.common.util.concurrent.ListeningExecutorService userExecutor)

Method Detail

createSimpleTimeLimiter

public static com.google.common.util.concurrent.SimpleTimeLimiter createSimpleTimeLimiter(ExecutorService executorService)

Reflective creation of SimpleTimeLimiter to allow compatibility with Guava 23.0. SimpleTimeLimiter.create(ExecutorService) was introduced in Guava 22.0 to replace the SimpleTimeLimiter(ExecutorService) constructor, which was deprecated in Guava 22.0 and removed in Guava 23.0. The method is public to allow test methods in other packages to use it.

Parameters:

executorService - the execution service to use when running time-limited tasks

Returns:

a new instance of SimpleTimeLimiter that uses executorService

configure

protected void configure()

Specified by:

configure in class com.google.inject.AbstractModule