systems.thoughtfull.amalgam.executors — systems.thoughtfull/amalgam 2.8.0

->ExecutorServiceComponent clj

(->ExecutorServiceComponent make-executor-service-fn
                            convey-bindings?
                            termination-wait-duration)

Positional factory function for class systems.thoughtfull.amalgam.executors.ExecutorServiceComponent.

An executor service that is also a component. It can be injected as a dependency of other components but also implements the ExecutorService interface.

• make-executor-service-fn — a function that takes the ExecutorServiceComponent as an argument and creates an ExecutorService for wrapping. Any options necessary for constructing an ExecutorService should be taken from the ExecutorServiceComponent.
• convey-bindings? — if true then convey thread local var bindings with tasks as they are submitted to the wrapped ExecutorService, defaults to true.
• termination-wait-duration — a java.time.Duration to wait for the ExecutorService to terminate when this component is stopped. A duration of zero means don't wait at all. If not specified, then wait indefinitely.

->ScheduledExecutorServiceComponent clj

(->ScheduledExecutorServiceComponent make-executor-service-fn
                                     convey-bindings?
                                     termination-wait-duration)

Positional factory function for class systems.thoughtfull.amalgam.executors.ScheduledExecutorServiceComponent.

An scheduled executor service that is also a component. It can be injected as a dependency of other components but also implements the ScheduledExecutorService interface.

• make-executor-service-fn — a function that takes the ScheduledExecutorServiceComponent as an argument and creates a ScheduledExecutorService for wrapping. Any options necessary for constructing an ScheduledExecutorService should be taken from the ScheduledExecutorServiceComponent.
• convey-bindings? — if true then convey thread local var bindings with tasks as they are submitted to the wrapped ExecutorService.
• termination-wait-duration — a java.time.Duration to wait for the ScheduledExecutorService to terminate when this component is stopped. A duration of zero means don't wait at all. If not specified, then wait indefinitely.

->ScheduledTaskComponent clj

(->ScheduledTaskComponent scheduled-executor-service make-scheduled-future-fn)

Positional factory function for class systems.thoughtfull.amalgam.executors.ScheduledTaskComponent.

A scheduled task that is also a component.

• executor-service — ScheduledExecutorService to use to schedule task. If not specified then a single thread scheduled-thread-pool component is started when this component is started and stopped when this component is stopped.
• make-scheduled-future-fn — a function that takes the ScheduledTaskComponent as an argument and creates a ScheduledFuture for wrapping. Any options necessary for constructing a ScheduledFuture should be taken from the ScheduledTaskComponent.

conveying-callable clj

(conveying-callable task)

conveying-runnable clj

(conveying-runnable task)

map->ExecutorServiceComponent clj

(map->ExecutorServiceComponent &
                               {:keys [make-executor-service-fn convey-bindings?
                                       termination-wait-duration]})

Factory function for class systems.thoughtfull.amalgam.executors.ExecutorServiceComponent, taking a map of keywords to field values.

An executor service that is also a component. It can be injected as a dependency of other components but also implements the ExecutorService interface.

• make-executor-service-fn — a function that takes the ExecutorServiceComponent as an argument and creates an ExecutorService for wrapping. Any options necessary for constructing an ExecutorService should be taken from the ExecutorServiceComponent.
• convey-bindings? — if true then convey thread local var bindings with tasks as they are submitted to the wrapped ExecutorService, defaults to true.
• termination-wait-duration — a java.time.Duration to wait for the ExecutorService to terminate when this component is stopped. A duration of zero means don't wait at all. If not specified, then wait indefinitely.

map->ScheduledExecutorServiceComponent clj

(map->ScheduledExecutorServiceComponent
  &
  {:keys [make-executor-service-fn convey-bindings? termination-wait-duration]})

Factory function for class systems.thoughtfull.amalgam.executors.ScheduledExecutorServiceComponent, taking a map of keywords to field values.

An scheduled executor service that is also a component. It can be injected as a dependency of other components but also implements the ScheduledExecutorService interface.

• make-executor-service-fn — a function that takes the ScheduledExecutorServiceComponent as an argument and creates a ScheduledExecutorService for wrapping. Any options necessary for constructing an ScheduledExecutorService should be taken from the ScheduledExecutorServiceComponent.
• convey-bindings? — if true then convey thread local var bindings with tasks as they are submitted to the wrapped ExecutorService.
• termination-wait-duration — a java.time.Duration to wait for the ScheduledExecutorService to terminate when this component is stopped. A duration of zero means don't wait at all. If not specified, then wait indefinitely.

map->ScheduledTaskComponent clj

(map->ScheduledTaskComponent &
                             {:keys [scheduled-executor-service
                                     make-scheduled-future-fn]})

Factory function for class systems.thoughtfull.amalgam.executors.ScheduledTaskComponent, taking a map of keywords to field values.

A scheduled task that is also a component.

• executor-service — ScheduledExecutorService to use to schedule task. If not specified then a single thread scheduled-thread-pool component is started when this component is started and stopped when this component is stopped.
• make-scheduled-future-fn — a function that takes the ScheduledTaskComponent as an argument and creates a ScheduledFuture for wrapping. Any options necessary for constructing a ScheduledFuture should be taken from the ScheduledTaskComponent.

scheduled-future clj

(scheduled-future {:keys [scheduled-future]})

Return wrapped ScheduledFuture from ScheduledTaskComponent. Throws IllegalStateException if the component is not started (i.e. it does not have an ScheduledFuture).