com.hazelcast.client.proxy

Class ClientSemaphoreProxy

java.lang.Object

com.hazelcast.client.spi.ClientProxy

com.hazelcast.client.proxy.ClientSemaphoreProxy

All Implemented Interfaces:

DistributedObject, ISemaphore

public class ClientSemaphoreProxy
extends ClientProxy
implements ISemaphore

Proxy implementation of ISemaphore.

Field Summary

Fields inherited from class com.hazelcast.client.spi.ClientProxy

name

Constructor Summary

Constructors

Constructor and Description
ClientSemaphoreProxy(String serviceName, String objectId, ClientContext context)

Method Summary

Modifier and Type	Method and Description
void	acquire() Acquires a permit if one is available, and returns immediately, reducing the number of available permits by one.
void	acquire(int permits) Acquires the given number of permits if they are available, and returns immediately, reducing the number of available permits by the given amount.
int	availablePermits() Returns the current number of permits currently available in this semaphore.
int	drainPermits() Acquires and returns all permits that are immediately available.
void	increasePermits(int increase) Increases the number of available permits by the indicated amount.
boolean	init(int permits) Try to initialize this ISemaphore instance with the given permit count
protected ClientMessage	invokeOnPartition(ClientMessage req)
protected <T> T	invokeOnPartition(ClientMessage clientMessage, long invocationTimeoutSeconds)
protected <T> ClientDelegatingFuture<T>	invokeOnPartitionAsync(ClientMessage clientMessage, ClientMessageDecoder clientMessageDecoder)
protected <T> T	invokeOnPartitionInterruptibly(ClientMessage clientMessage)
protected <T> T	invokeOnPartitionInterruptibly(ClientMessage clientMessage, long invocationTimeoutSeconds)
protected void	onInitialize() Called when proxy is created.
void	reducePermits(int reduction) Shrinks the number of available permits by the indicated reduction.
void	release() Releases a permit, increasing the number of available permits by one.
void	release(int permits) Releases the given number of permits, increasing the number of available permits by that amount.
String	toString()
boolean	tryAcquire() Acquires a permit, if one is available and returns immediately, with the value true, reducing the number of available permits by one.
boolean	tryAcquire(int permits) Acquires the given number of permits, if they are available, and returns immediately, with the value true, reducing the number of available permits by the given amount.
boolean	tryAcquire(int permits, long timeout, TimeUnit unit) Acquires the given number of permits if they are available and returns immediately with the value true, reducing the number of available permits by the given amount.
boolean	tryAcquire(long timeout, TimeUnit unit) Acquires a permit from this semaphore if one becomes available within the given waiting time and the current thread has not been interrupted.

Methods inherited from class com.hazelcast.client.spi.ClientProxy

deregisterListener, destroy, destroyLocally, destroyRemotely, equals, getClient, getConnectedServerVersion, getContext, getDistributedObjectName, getId, getName, getPartitionKey, getSerializationService, getServiceName, hashCode, invoke, invoke, invokeOnAddress, invokeOnPartition, invokeOnPartitionInterruptibly, onDestroy, onShutdown, postDestroy, preDestroy, registerListener, setContext, toData, toObject

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.hazelcast.core.ISemaphore

getName

Methods inherited from interface com.hazelcast.core.DistributedObject

destroy, getPartitionKey, getServiceName

Constructor Detail

ClientSemaphoreProxy

public ClientSemaphoreProxy(String serviceName,
                            String objectId,
                            ClientContext context)

Method Detail

init

public boolean init(int permits)

Description copied from interface: ISemaphore

Try to initialize this ISemaphore instance with the given permit count

Specified by:

init in interface ISemaphore

Parameters:

permits - the given permit count

Returns:

true if initialization success

acquire

public void acquire()
             throws InterruptedException

Description copied from interface: ISemaphore

Acquires a permit if one is available, and returns immediately, reducing the number of available permits by one.

If no permit is available, then the current thread becomes disabled for thread scheduling purposes and lies dormant until one of three things happens:

• some other thread invokes one of the ISemaphore.release() methods for this semaphore and the current thread is next to be assigned a permit,
• this ISemaphore instance is destroyed, or
• some other thread interrupts the current thread.

If the current thread:

• has its interrupted status set on entry to this method; or
• is interrupted while waiting for a permit,

then InterruptedException is thrown and the current thread's interrupted status is cleared.

Specified by:

acquire in interface ISemaphore

Throws:

InterruptedException - if the current thread is interrupted

acquire

public void acquire(int permits)
             throws InterruptedException

Description copied from interface: ISemaphore

Acquires the given number of permits if they are available, and returns immediately, reducing the number of available permits by the given amount.

If insufficient permits are available then the current thread becomes disabled for thread scheduling purposes and lies dormant until one of three things happens:

• some other thread invokes one of the release methods for this semaphore, the current thread is next to be assigned permits and the number of available permits satisfies this request,
• this ISemaphore instance is destroyed, or
• some other thread interrupts the current thread.

If the current thread:

• has its interrupted status set on entry to this method, or
• is interrupted while waiting for a permit,

then InterruptedException is thrown and the current thread's interrupted status is cleared.

Specified by:

acquire in interface ISemaphore

Parameters:

permits - the number of permits to acquire

Throws:

InterruptedException - if the current thread is interrupted

availablePermits

public int availablePermits()

Description copied from interface: ISemaphore

Returns the current number of permits currently available in this semaphore.

This method is typically used for debugging and testing purposes.

Specified by:

availablePermits in interface ISemaphore

Returns:

the number of permits available in this semaphore

drainPermits

public int drainPermits()

Description copied from interface: ISemaphore

Acquires and returns all permits that are immediately available.

Specified by:

drainPermits in interface ISemaphore

Returns:

the number of permits drained

reducePermits

public void reducePermits(int reduction)

Description copied from interface: ISemaphore

Shrinks the number of available permits by the indicated reduction.

This method differs from acquire in that it does not block waiting for permits to become available.

Specified by:

reducePermits in interface ISemaphore

Parameters:

reduction - the number of permits to remove

increasePermits

public void increasePermits(int increase)

Description copied from interface: ISemaphore

Increases the number of available permits by the indicated amount. This method differs from release in that it does not effect the amount of permits this caller has attached.

Specified by:

increasePermits in interface ISemaphore

Parameters:

increase - the number of permits to add

release

public void release()

Description copied from interface: ISemaphore

Releases a permit, increasing the number of available permits by one. If any threads in the cluster are trying to acquire a permit, then one is selected and given the permit that was just released.

There is no requirement that a thread that releases a permit must have acquired that permit by calling one of the acquire methods. Correct usage of a semaphore is established by programming convention in the application.

Specified by:

release in interface ISemaphore

release

public void release(int permits)

Description copied from interface: ISemaphore

Releases the given number of permits, increasing the number of available permits by that amount.

There is no requirement that a thread that releases a permit must have acquired that permit by calling one of the acquire methods. Correct usage of a semaphore is established by programming convention in the application.

Specified by:

release in interface ISemaphore

Parameters:

permits - the number of permits to release

tryAcquire

public boolean tryAcquire()

Description copied from interface: ISemaphore

Acquires a permit, if one is available and returns immediately, with the value true, reducing the number of available permits by one.

If no permit is available then this method will return immediately with the value false.

Specified by:

tryAcquire in interface ISemaphore

Returns:

true if a permit was acquired and false otherwise

tryAcquire

public boolean tryAcquire(int permits)

Description copied from interface: ISemaphore

Acquires the given number of permits, if they are available, and returns immediately, with the value true, reducing the number of available permits by the given amount.

If insufficient permits are available then this method will return immediately with the value false and the number of available permits is unchanged.

Specified by:

tryAcquire in interface ISemaphore

Parameters:

permits - the number of permits to acquire

Returns:

true if the permits were acquired and false otherwise

tryAcquire

public boolean tryAcquire(long timeout,
                          TimeUnit unit)
                   throws InterruptedException

Description copied from interface: ISemaphore

Acquires a permit from this semaphore if one becomes available within the given waiting time and the current thread has not been interrupted.

Acquires a permit if one is available and returns immediately with the value true, reducing the number of available permits by one.

If no permit is available, then the current thread becomes disabled for thread scheduling purposes and lies dormant until one of three things happens:

• some other thread invokes the ISemaphore.release() method for this semaphore and the current thread is next to be assigned a permit, or
• some other thread interrupts the current thread, or
• the specified waiting time elapses.

If a permit is acquired then the value true is returned.

If the specified waiting time elapses then the value false is returned. If the time is less than or equal to zero, the method will not wait at all.

If the current thread:

• has its interrupted status set on entry to this method; or
• is interrupted while waiting
for a permit,

then InterruptedException is thrown and the current thread's interrupted status is cleared.

Specified by:

tryAcquire in interface ISemaphore

Parameters:

timeout - the maximum time to wait for a permit

unit - the time unit of the timeout argument

Returns:

true if a permit was acquired and false if the waiting time elapsed before a permit was acquired

Throws:

InterruptedException - if the current thread is interrupted

tryAcquire

public boolean tryAcquire(int permits,
                          long timeout,
                          TimeUnit unit)
                   throws InterruptedException

Description copied from interface: ISemaphore

Acquires the given number of permits if they are available and returns immediately with the value true, reducing the number of available permits by the given amount.

If insufficient permits are available, then the current thread becomes disabled for thread scheduling purposes and lies dormant until one of three things happens:

• some other thread invokes one of the release methods for this semaphore, the current thread is next to be assigned permits and the number of available permits satisfies this request, or
• some other thread interrupts the current thread, or
• the specified waiting time elapses.

If the permits are acquired then true is returned.

If the specified waiting time elapses then false is returned. If the time is less than or equal to zero, the method will not wait at all.

If the current thread:

• has its interrupted status set on entry to this method, or
• is interrupted while waiting
for a permit,

then InterruptedException is thrown and the current thread's interrupted status is cleared.

Specified by:

tryAcquire in interface ISemaphore

Parameters:

permits - the number of permits to acquire

timeout - the maximum time to wait for the permits

unit - the time unit of the timeout argument

Returns:

true if all permits were acquired, false if the waiting time elapsed before all permits could be acquired

Throws:

InterruptedException - if the current thread is interrupted

toString

public String toString()

Overrides:

toString in class Object

onInitialize

protected void onInitialize()

Description copied from class: ClientProxy

Called when proxy is created. Overriding implementations can add initialization specific logic into this method like registering a listener, creating a cleanup task etc.

Overrides:

onInitialize in class ClientProxy

invokeOnPartition

protected ClientMessage invokeOnPartition(ClientMessage req)

invokeOnPartitionInterruptibly

protected <T> T invokeOnPartitionInterruptibly(ClientMessage clientMessage)
                                        throws InterruptedException

Throws:

InterruptedException

invokeOnPartitionAsync

protected <T> ClientDelegatingFuture<T> invokeOnPartitionAsync(ClientMessage clientMessage,
                                                               ClientMessageDecoder clientMessageDecoder)

invokeOnPartition

protected <T> T invokeOnPartition(ClientMessage clientMessage,
                                  long invocationTimeoutSeconds)

invokeOnPartitionInterruptibly

protected <T> T invokeOnPartitionInterruptibly(ClientMessage clientMessage,
                                               long invocationTimeoutSeconds)
                                        throws InterruptedException

Throws:

InterruptedException