Package | Description |
---|---|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.scheduledexecutor |
This package contains ScheduledExecutorService functionality for Hazelcast.
The ScheduledExecutorService provides functionality similar to ExecutorService
and also additional methods like executing tasks on a member who is owner of a specific key. |
com.hazelcast.scheduledexecutor.impl |
Modifier and Type | Class and Description |
---|---|
class |
ClientScheduledFutureProxy<V>
Proxy implementation of
IScheduledFuture . |
Modifier and Type | Method and Description |
---|---|
<V> IScheduledFuture<V> |
ClientScheduledExecutorProxy.getScheduledFuture(ScheduledTaskHandler handler) |
<V> IScheduledFuture<V> |
ClientScheduledExecutorProxy.schedule(Callable<V> command,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ClientScheduledExecutorProxy.schedule(Runnable command,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ClientScheduledExecutorProxy.scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit) |
<V> IScheduledFuture<V> |
ClientScheduledExecutorProxy.scheduleOnKeyOwner(Callable<V> command,
Object key,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ClientScheduledExecutorProxy.scheduleOnKeyOwner(Runnable command,
Object key,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ClientScheduledExecutorProxy.scheduleOnKeyOwnerAtFixedRate(Runnable command,
Object key,
long initialDelay,
long period,
TimeUnit unit) |
<V> IScheduledFuture<V> |
ClientScheduledExecutorProxy.scheduleOnMember(Callable<V> command,
Member member,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ClientScheduledExecutorProxy.scheduleOnMember(Runnable command,
Member member,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ClientScheduledExecutorProxy.scheduleOnMemberAtFixedRate(Runnable command,
Member member,
long initialDelay,
long period,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,List<IScheduledFuture<V>>> |
ClientScheduledExecutorProxy.getAllScheduledFutures() |
<V> Map<Member,IScheduledFuture<V>> |
ClientScheduledExecutorProxy.scheduleOnAllMembers(Callable<V> command,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnAllMembers(Runnable command,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnAllMembersAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit) |
<V> Map<Member,IScheduledFuture<V>> |
ClientScheduledExecutorProxy.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
<V> IScheduledFuture<V> |
IScheduledExecutorService.getScheduledFuture(ScheduledTaskHandler handler)
Creates a new
IScheduledFuture from the given handler. |
<V> IScheduledFuture<V> |
IScheduledExecutorService.schedule(Callable<V> command,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay.
|
IScheduledFuture<?> |
IScheduledExecutorService.schedule(Runnable command,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay.
|
IScheduledFuture<?> |
IScheduledExecutorService.scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first
after the given initial delay, and subsequently with the given
period.
|
<V> IScheduledFuture<V> |
IScheduledExecutorService.scheduleOnKeyOwner(Callable<V> command,
Object key,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay on the partition owner of the given key.
|
IScheduledFuture<?> |
IScheduledExecutorService.scheduleOnKeyOwner(Runnable command,
Object key,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay on the partition owner of the given key.
|
IScheduledFuture<?> |
IScheduledExecutorService.scheduleOnKeyOwnerAtFixedRate(Runnable command,
Object key,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first
after the given initial delay, and subsequently with the given
period on the partition owner of the given key.
|
<V> IScheduledFuture<V> |
IScheduledExecutorService.scheduleOnMember(Callable<V> command,
Member member,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay at the given
Member . |
IScheduledFuture<?> |
IScheduledExecutorService.scheduleOnMember(Runnable command,
Member member,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay at the given
Member . |
IScheduledFuture<?> |
IScheduledExecutorService.scheduleOnMemberAtFixedRate(Runnable command,
Member member,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first
after the given initial delay, and subsequently with the given
period at the given
Member . |
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,List<IScheduledFuture<V>>> |
IScheduledExecutorService.getAllScheduledFutures()
Fetches and returns all scheduled (not disposed yet) futures from all members in the cluster.
|
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnAllMembers(Callable<V> command,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay on all cluster
Member s. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnAllMembers(Runnable command,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay on all cluster
Member s. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnAllMembersAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first
after the given initial delay, and subsequently with the given
period on all cluster
Member s. |
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay on all
Member s given. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled
after the given delay on all
Member s given. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first
after the given initial delay, and subsequently with the given
period on all
Member s given. |
Modifier and Type | Class and Description |
---|---|
class |
ScheduledFutureProxy<V> |
Modifier and Type | Method and Description |
---|---|
IScheduledFuture<?> |
ScheduledExecutorServiceProxy.getScheduledFuture(ScheduledTaskHandler handler) |
<V> IScheduledFuture<V> |
ScheduledExecutorServiceProxy.schedule(Callable<V> command,
long delay,
TimeUnit unit) |
IScheduledFuture |
ScheduledExecutorServiceProxy.schedule(Runnable command,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ScheduledExecutorServiceProxy.scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit) |
<V> IScheduledFuture<V> |
ScheduledExecutorServiceProxy.scheduleOnKeyOwner(Callable<V> command,
Object key,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ScheduledExecutorServiceProxy.scheduleOnKeyOwner(Runnable command,
Object key,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ScheduledExecutorServiceProxy.scheduleOnKeyOwnerAtFixedRate(Runnable command,
Object key,
long initialDelay,
long period,
TimeUnit unit) |
<V> IScheduledFuture<V> |
ScheduledExecutorServiceProxy.scheduleOnMember(Callable<V> command,
Member member,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ScheduledExecutorServiceProxy.scheduleOnMember(Runnable command,
Member member,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ScheduledExecutorServiceProxy.scheduleOnMemberAtFixedRate(Runnable command,
Member member,
long initialDelay,
long period,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,List<IScheduledFuture<V>>> |
ScheduledExecutorServiceProxy.getAllScheduledFutures() |
<V> Map<Member,IScheduledFuture<V>> |
ScheduledExecutorServiceProxy.scheduleOnAllMembers(Callable<V> command,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnAllMembers(Runnable command,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnAllMembersAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit) |
<V> Map<Member,IScheduledFuture<V>> |
ScheduledExecutorServiceProxy.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit) |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.