A class useful for offloading waiting and signalling operations
on single int variables.
| Method from EDU.oswego.cs.dl.util.concurrent.WaitableInt Detail: |
|---|
 public int add(int amount) {
synchronized (lock_) {
lock_.notifyAll();
return super.add(amount);
}
}
|
public int and(int b) {
synchronized (lock_) {
value_ = value_ & b;
lock_.notifyAll();
return value_;
}
} |
public boolean commit(int assumedValue,
int newValue) {
synchronized (lock_) {
boolean success = super.commit(assumedValue, newValue);
if (success) lock_.notifyAll();
return success;
}
} |
public int complement() {
synchronized (lock_) {
value_ = ~value_;
lock_.notifyAll();
return value_;
}
} Set the value to its complement |
public int decrement() {
synchronized (lock_) {
lock_.notifyAll();
return super.decrement();
}
} |
public int divide(int factor) {
synchronized (lock_) {
lock_.notifyAll();
return super.divide(factor);
}
} |
public int increment() {
synchronized (lock_) {
lock_.notifyAll();
return super.increment();
}
} |
public int multiply(int factor) {
synchronized (lock_) {
lock_.notifyAll();
return super.multiply(factor);
}
} |
public int or(int b) {
synchronized (lock_) {
value_ = value_ | b;
lock_.notifyAll();
return value_;
}
} |
public int set(int newValue) {
synchronized (lock_) {
lock_.notifyAll();
return super.set(newValue);
}
} |
public int subtract(int amount) {
synchronized (lock_) {
lock_.notifyAll();
return super.subtract(amount);
}
} |
public void whenEqual(int 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(int 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(int 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(int 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(int 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(int 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 int xor(int b) {
synchronized (lock_) {
value_ = value_ ^ b;
lock_.notifyAll();
return value_;
}
} |
EDU.oswego.cs.dl.util.concurrent.SynchronizedVariable