public class DistributedSemaphore extends Object implements DataSerializable
Constructor and Description |
---|
DistributedSemaphore() |
DistributedSemaphore(int initialPermits) |
Modifier and Type | Method and Description |
---|---|
void |
attachDetach(Integer permitsDelta,
Address address) |
int |
drain() |
int |
getAttached() |
int |
getAttached(Address address) |
int |
getAvailable() |
boolean |
onDisconnect(Address deadAddress) |
void |
readData(DataInput in) |
void |
reduce(int permits) |
void |
release(int permits,
Address address) |
String |
toString() |
boolean |
tryAcquire(int permits,
Address address) |
void |
writeData(DataOutput out) |
public DistributedSemaphore()
public DistributedSemaphore(int initialPermits)
public void readData(DataInput in) throws IOException
readData
in interface DataSerializable
IOException
public void writeData(DataOutput out) throws IOException
writeData
in interface DataSerializable
IOException
public int drain()
public int getAttached()
public int getAttached(Address address)
public int getAvailable()
public void reduce(int permits)
public void release(int permits, Address address)
public boolean tryAcquire(int permits, Address address)
public boolean onDisconnect(Address deadAddress)
Copyright © 2013 Hazelcast, Inc.. All rights reserved.