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

[Alexey Kuznetsov (JIRA)]

Title: Message Title

Alexey Kuznetsov commented on IGNITE-4492   Re: Add MBean for StripedExecutor попробовал запустить вот такой код(отрывок): 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); } } } Но executor начинает себя странно вести . А именно в этом месте кода : void execute(Runnable cmd) { queue.add(cmd); if (parked) LockSupport.unpark(thread); } вызов LockSupport.unpark(thread); очищает очередь Add Comment   This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)