[jira] (IGNITE-4492) Add MBean for StripedExecutor

[Alexey Kuznetsov (JIRA)]

Title: Message Title

Alexey Kuznetsov edited a comment on IGNITE-4492   Re: Add MBean for StripedExecutor попробовал запустить вот такой код(отрывок): {code} public void testQueueSize() throws Exception { //        before();         stripedExecSvc = new StripedExecutor(3, "foo name", "pool name", new JavaLogger());         stripedExecSvc.execute(1, new TestRunnable(true)); //        stripedExecSvc.execute(0, new TestRunnable(true)); //        stripedExecSvc.execute(1, new TestRunnable()); //        sleepASec(); //        assertEquals(2, stripedExecSvc.queueSize()); //        after();     }     private final class TestRunnable implements Runnable {         private boolean infinitely;         public TestRunnable() {             super();         }         public TestRunnable(boolean infinitely) {             this.infinitely = infinitely;         }         @Override         public void run() {             try {                 while (infinitely) {                     Thread.sleep(10000);                 }             } catch (InterruptedException e) {                 info("Got interrupted exception while sleeping: " + e);             }         }     } {code} Но executor начинает себя странно вести . А именно в этом месте кода : {code}         void execute(Runnable cmd) {             queue.add(cmd);             if (parked)                 LockSupport.unpark(thread);         } {code} вызов LockSupport.unpark(thread); очищает очередь Add Comment   This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)