A class useful for offloading waiting and signalling operations
on single byte variables.
Method from EDU.oswego.cs.dl.util.concurrent.WaitableByte Detail: |
public byte add(byte amount) {
synchronized (lock_) {
lock_.notifyAll();
return super.add(amount);
}
}
|
public byte and(byte b) {
synchronized (lock_) {
value_ = (byte)(value_ & b);
lock_.notifyAll();
return value_;
}
}
|
public boolean commit(byte assumedValue,
byte newValue) {
synchronized (lock_) {
boolean success = super.commit(assumedValue, newValue);
if (success) lock_.notifyAll();
return success;
}
}
|
public byte complement() {
synchronized (lock_) {
value_ = (byte)~value_;
lock_.notifyAll();
return value_;
}
}
Set the value to its complement |
public byte decrement() {
synchronized (lock_) {
lock_.notifyAll();
return super.decrement();
}
}
|
public byte divide(byte factor) {
synchronized (lock_) {
lock_.notifyAll();
return super.divide(factor);
}
}
|
public byte increment() {
synchronized (lock_) {
lock_.notifyAll();
return super.increment();
}
}
|
public byte multiply(byte factor) {
synchronized (lock_) {
lock_.notifyAll();
return super.multiply(factor);
}
}
|
public byte or(byte b) {
synchronized (lock_) {
value_ = (byte)(value_ | b);
lock_.notifyAll();
return value_;
}
}
|
public byte set(byte newValue) {
synchronized (lock_) {
lock_.notifyAll();
return super.set(newValue);
}
}
|
public byte subtract(byte amount) {
synchronized (lock_) {
lock_.notifyAll();
return super.subtract(amount);
}
}
|
public void whenEqual(byte c,
Runnable action) throws InterruptedException {
synchronized(lock_) {
while (!(value_ == c)) lock_.wait();
if (action != null) action.run();
}
}
Wait until value equals c, then run action if nonnull.
The action is run with the synchronization lock held.
* |
public void whenGreater(byte c,
Runnable action) throws InterruptedException {
synchronized (lock_) {
while (!(value_ > c)) lock_.wait();
if (action != null) action.run();
}
}
wait until value greater than c, then run action if nonnull.
The action is run with the synchronization lock held.
* |
public void whenGreaterEqual(byte c,
Runnable action) throws InterruptedException {
synchronized (lock_) {
while (!(value_ >= c)) lock_.wait();
if (action != null) action.run();
}
}
wait until value greater than or equal to c, then run action if nonnull.
The action is run with the synchronization lock held.
* |
public void whenLess(byte c,
Runnable action) throws InterruptedException {
synchronized (lock_) {
while (!(value_ < c)) lock_.wait();
if (action != null) action.run();
}
}
wait until value less than c, then run action if nonnull.
The action is run with the synchronization lock held.
* |
public void whenLessEqual(byte c,
Runnable action) throws InterruptedException {
synchronized (lock_) {
while (!(value_ < = c)) lock_.wait();
if (action != null) action.run();
}
}
wait until value less than or equal to c, then run action if nonnull.
The action is run with the synchronization lock held.
* |
public void whenNotEqual(byte c,
Runnable action) throws InterruptedException {
synchronized (lock_) {
while (!(value_ != c)) lock_.wait();
if (action != null) action.run();
}
}
wait until value not equal to c, then run action if nonnull.
The action is run with the synchronization lock held.
* |
public byte xor(byte b) {
synchronized (lock_) {
value_ = (byte)(value_ ^ b);
lock_.notifyAll();
return value_;
}
}
|