RunnablesReferenceQueue - a reference queue for Reference objects that implement Runnable (will be run when enqueued) [1035343]

< > BotCompany Repo | #1035343 // RunnablesReferenceQueue - a reference queue for Reference objects that implement Runnable (will be run when enqueued)

JavaX fragment (include) [tags: use-pretranspiled]

// Note: Costs one thread while it exists
sclass RunnablesReferenceQueue is AutoCloseable {
  new ReferenceQueue queue;
  volatile Thread thread;
  new Flag closed;
  
  settable int timeout = 60000; // just for safety
  
  *() {
    thread = startThread("RunnablesReferenceQueue", l0 _run);
  }
  
  void _run() ctex {
    try {
      while (ping() && !closed!) {
        Reference<?> ref = queue.remove(timeout);
        if (ref != null) {
          if (ref cast Runnable)
            pcallF(ref);
          else
            warn("RunnablesReferenceQueue: Reference not runnable - "
              + className(ref));
        }
      }
    } catch InterruptedException e {
    } finally {
      thread = null;
    }
  }
  
  close {
    closed.raise();
    interruptThread(thread);
  }
  
  ReferenceQueue queue aka get() { ret queue; }
}

Travelled to 3 computer(s): ekrmjmnbrukm, mowyntqkapby, mqqgnosmbjvj

Snippet ID:

#1035343

Snippet name:

RunnablesReferenceQueue - a reference queue for Reference objects that implement Runnable (will be run when enqueued)

Eternal ID of this version:

#1035343/8

Text MD5:

ad201c5e28da5e4b4a5c0b7d0a090d73

Transpilation MD5:

a94b06f65bbed36ed583bc03332336e3

Author:

stefan

Category:

javax

Type:

JavaX fragment (include)

Public (visible to everyone):

Yes

Archived (hidden from active list):

Created/modified:

2022-05-01 19:11:37

Source code size:

874 bytes / 37 lines

Pitched / IR pitched:

No / No

Views / Downloads:

693 / 875

Version history:

7 change(s)

Referenced in:

[show references]

1	// Note: Costs one thread while it exists
2	sclass RunnablesReferenceQueue is AutoCloseable {
3	new ReferenceQueue queue;
4	volatile Thread thread;
5	new Flag closed;
6
7	settable int timeout = 60000; // just for safety
8
9	*() {
10	thread = startThread("RunnablesReferenceQueue", l0 _run);
11	}
12
13	void _run() ctex {
14	try {
15	while (ping() && !closed!) {
16	Reference<?> ref = queue.remove(timeout);
17	if (ref != null) {
18	if (ref cast Runnable)
19	pcallF(ref);
20	else
21	warn("RunnablesReferenceQueue: Reference not runnable - "
22	+ className(ref));
23	}
24	}
25	} catch InterruptedException e {
26	} finally {
27	thread = null;
28	}
29	}
30
31	close {
32	closed.raise();
33	interruptThread(thread);
34	}
35
36	ReferenceQueue queue aka get() { ret queue; }
37	}