Package java.util.concurrent

Examples of java.util.concurrent.LinkedBlockingQueue.clear()

129
130
131
132
133
134
135
136
137
138
139
        };
        taker.start();

        Util.sleep(500);

        queue.clear(); // does this release the taker thread ?
        Util.interruptAndWaitToDie(taker);
        assert !(taker.isAlive()) : "taker: " + taker;
    }

View Full Code Here
206
207
208
209
210
211
212
213
214
215
216
        } finally {
            //clear entry from map
          if (entry.removeRequest()) {
                reposMap.remove(id);
                if(aQueue != null) {
                    aQueue.clear();
                    repos.getQueueForQueues().offer(aQueue);
                }
          }
        }
        return result;
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
    eventBus.enableCatchAllSubscriber(q);
    eventBus.publish(new Event("name", 1));
        assertEquals("No event enqueued to catch all subscriber.", 1, testAwareQueue.offeredCount.get());
        assertNotNull("No event enqueued to catch all subscriber sink under 1 second.", q.poll(1, TimeUnit.SECONDS));
        eventBus.disableCatchAllSubscriber();
        q.clear();
        testAwareQueue.offeredCount.set(0);

        eventBus.publish(new Event("name", 1));
        assertEquals("Event enqueued to catch all subscriber after disable.", 0, testAwareQueue.offeredCount.get());
        assertNull("Event enqueued to catch all subscriber sink under 1 second after disable.", q.poll(1, TimeUnit.SECONDS));
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
                return retrieved;
            }

            @Override
            public void clear() {
                delegate.clear();
                queueSizeCounter.set(0);
            }
        };
    }
}
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
        };
        taker.start();

        Util.sleep(500);

        queue.clear(); // does this release the taker thread ?
        Util.interruptAndWaitToDie(taker);
        assert !(taker.isAlive()) : "taker: " + taker;
    }

View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.