Imbus/EDAF85-labs
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Debugging output

Browse source
This commit is contained in:
Imbus 2024-11-07 01:54:44 +01:00
parent 6a88b3fa56
commit 49ec551e69
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
wash/src/actor/ActorThread.java
View file

@ -10,14 +10,18 @@ public abstract class ActorThread<M> extends Thread {
/** Called by another thread, to send a message to this thread. */
public void send(M message) {
System.out.println(" # Sending message: " + message);
q.offer(message);
System.out.println(" % Queue State: " + q);
}
/** Returns the first message in the queue, or blocks if none available. */
protected M receive() throws InterruptedException {
return q.take();
M mess = q.take();
System.out.println(" - Message taken: " + mess);
return mess;
}
/** Returns the first message in the queue, or blocks up to 'timeout'
milliseconds if none available. Returns null if no message is obtained
within 'timeout' milliseconds. */
@ -27,7 +31,9 @@ public abstract class ActorThread<M> extends Thread {
protected Optional<M> poll(long timeOut) {
try {
return Optional.ofNullable(q.poll(timeOut, TimeUnit.MILLISECONDS));
Optional<M> m = Optional.ofNullable(q.poll(timeOut, TimeUnit.MILLISECONDS));
System.out.println("Stolen: " + m);
return m;
} catch (InterruptedException e) {
return Optional.empty();
} catch (Exception e) {