CachedThreadPoolPromiseFactory (Grails 7.0.1)

org.grails.async.factory.future.CachedThreadPoolPromiseFactory

All Implemented Interfaces and Traits:: java.io.Closeable, ExecutorPromiseFactory

@groovy.transform.AutoFinal
@groovy.transform.CompileStatic
class CachedThreadPoolPromiseFactory
extends AbstractPromiseFactory
implements java.io.Closeable, ExecutorPromiseFactory

A promise factory that uses an ExecutorService by default

Authors:: Graeme Rocher

Since:: 3.3

Nested Class Summary

Nested classes
Modifiers	Name	Description
`class`	`CachedThreadPoolPromiseFactory.1`

Inherited fields
Fields inherited from class	Fields
`class AbstractPromiseFactory`	`lookupStrategies`

Properties Summary

Properties
Type	Name and description
`java.util.concurrent.ExecutorService`	`executorService`

Constructor Summary

Constructors
Constructor and description
`CachedThreadPoolPromiseFactory(int maxPoolSize, long timeout, java.util.concurrent.TimeUnit unit)`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`void`	`close()`
`<T>`	`Promise<T>`	`createPromise(java.lang.Class<T> returnType)`
	`Promise<java.lang.Object>`	`createPromise()`
`<T>`	`Promise<T>`	`createPromise(groovy.lang.Closure<T>[] closures)`
`<T>`	`Promise<java.util.List<T>>`	`onComplete(java.util.List<Promise<T>> promises, groovy.lang.Closure<T> callable)`
`<T>`	`Promise<java.util.List<T>>`	`onError(java.util.List<Promise<T>> promises, groovy.lang.Closure<?> callable)`
`<T>`	`java.util.List<T>`	`waitAll(java.util.List<Promise<T>> promises)`
`<T>`	`java.util.List<T>`	`waitAll(java.util.List<Promise<T>> promises, long timeout, java.util.concurrent.TimeUnit units)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class AbstractPromiseFactory`	`addPromiseDecoratorLookupStrategy, applyDecorators, createBoundPromise, createPromise, createPromise, createPromise, createPromise, createPromise, createPromise, createPromiseInternal, waitAll`

- Property Detail
  - @groovy.lang.Delegate
    final java.util.concurrent.ExecutorService executorService
- Constructor Detail
  - CachedThreadPoolPromiseFactory(int maxPoolSize, long timeout, java.util.concurrent.TimeUnit unit)
- Method Detail
  - @java.lang.Override
    @jakarta.annotation.PreDestroy
    void close()
  - <T> @java.lang.Override
    Promise<T> createPromise(java.lang.Class<T> returnType)
  - @java.lang.Override
    Promise<java.lang.Object> createPromise()
  - <T> @java.lang.Override
    Promise<T> createPromise(groovy.lang.Closure<T>[] closures)
  - <T> @java.lang.Override
    Promise<java.util.List<T>> onComplete(java.util.List<Promise<T>> promises, groovy.lang.Closure<T> callable)
  - <T> @java.lang.Override
    Promise<java.util.List<T>> onError(java.util.List<Promise<T>> promises, groovy.lang.Closure<?> callable)
  - <T> @java.lang.Override
    java.util.List<T> waitAll(java.util.List<Promise<T>> promises)
  - <T> @java.lang.Override
    java.util.List<T> waitAll(java.util.List<Promise<T>> promises, long timeout, java.util.concurrent.TimeUnit units)

Summary:
Nested
Property
Constructor
Method

| Detail:
Property
Constructor
Method

Groovy Documentation

[Groovy] Class CachedThreadPoolPromiseFactory

Nested Class Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Property Detail

@groovy.lang.Delegate
final java.util.concurrent.ExecutorService executorService

Constructor Detail

CachedThreadPoolPromiseFactory(int maxPoolSize, long timeout, java.util.concurrent.TimeUnit unit)

Method Detail

@java.lang.Override
@jakarta.annotation.PreDestroy
void close()

<T> @java.lang.Override
Promise<T> createPromise(java.lang.Class<T> returnType)

@java.lang.Override
Promise<java.lang.Object> createPromise()

<T> @java.lang.Override
Promise<T> createPromise(groovy.lang.Closure<T>[] closures)

<T> @java.lang.Override
Promise<java.util.List<T>> onComplete(java.util.List<Promise<T>> promises, groovy.lang.Closure<T> callable)

<T> @java.lang.Override
Promise<java.util.List<T>> onError(java.util.List<Promise<T>> promises, groovy.lang.Closure<?> callable)

<T> @java.lang.Override
java.util.List<T> waitAll(java.util.List<Promise<T>> promises)

<T> @java.lang.Override
java.util.List<T> waitAll(java.util.List<Promise<T>> promises, long timeout, java.util.concurrent.TimeUnit units)

[Groovy] Class CachedThreadPoolPromiseFactory

Nested Class Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Property Detail

@groovy.lang.Delegatefinal java.util.concurrent.ExecutorService executorService

Constructor Detail

CachedThreadPoolPromiseFactory(int maxPoolSize, long timeout, java.util.concurrent.TimeUnit unit)

Method Detail

@java.lang.Override@jakarta.annotation.PreDestroyvoid close()

<T> @java.lang.OverridePromise<T> createPromise(java.lang.Class<T> returnType)

@java.lang.OverridePromise<java.lang.Object> createPromise()

<T> @java.lang.OverridePromise<T> createPromise(groovy.lang.Closure<T>[] closures)

<T> @java.lang.OverridePromise<java.util.List<T>> onComplete(java.util.List<Promise<T>> promises, groovy.lang.Closure<T> callable)

<T> @java.lang.OverridePromise<java.util.List<T>> onError(java.util.List<Promise<T>> promises, groovy.lang.Closure<?> callable)

<T> @java.lang.Overridejava.util.List<T> waitAll(java.util.List<Promise<T>> promises)

<T> @java.lang.Overridejava.util.List<T> waitAll(java.util.List<Promise<T>> promises, long timeout, java.util.concurrent.TimeUnit units)

@groovy.lang.Delegate
final java.util.concurrent.ExecutorService executorService

@java.lang.Override
@jakarta.annotation.PreDestroy
void close()

<T> @java.lang.Override
Promise<T> createPromise(java.lang.Class<T> returnType)

@java.lang.Override
Promise<java.lang.Object> createPromise()

<T> @java.lang.Override
Promise<T> createPromise(groovy.lang.Closure<T>[] closures)

<T> @java.lang.Override
Promise<java.util.List<T>> onComplete(java.util.List<Promise<T>> promises, groovy.lang.Closure<T> callable)

<T> @java.lang.Override
Promise<java.util.List<T>> onError(java.util.List<Promise<T>> promises, groovy.lang.Closure<?> callable)

<T> @java.lang.Override
java.util.List<T> waitAll(java.util.List<Promise<T>> promises)

<T> @java.lang.Override
java.util.List<T> waitAll(java.util.List<Promise<T>> promises, long timeout, java.util.concurrent.TimeUnit units)