marking Thread as interrupted

Author: Vitalii Cherkashyn

thread/Interrupted.java

@@ -0,0 +1,21 @@
+public class PrimeProducer extends Thread {
+ private final BlockingQueue<BigInteger> queue;
+ 
+ PrimeProducer(BlockingQueue<BigInteger> queue) {
+ this.queue = queue;
+ }
+ 
+ public void run() {
+ try {
+ BigInteger p = BigInteger.ONE;
+ // check 'interrupted' flag
+ while (!Thread.currentThread().isInterrupted())
+ queue.put(p = p.nextProbablePrime());
+ } catch (InterruptedException consumed) {
+ /* Allow thread to exit */
+ }
+ }
+ 
+ // mark Thread as 'interrupted'
+ public void cancel() { interrupt(); }
+}