How to use SynchronisingInvocationDispatcherWrapper method of org.jmock.lib.concurrent.SynchronisingInvocationDispatcherWrapper class

Best Jmock-library code snippet using org.jmock.lib.concurrent.SynchronisingInvocationDispatcherWrapper.SynchronisingInvocationDispatcherWrapper

Source:InvocationDispatcherTests.java

...11import org.jmock.api.ExpectationError;12import org.jmock.api.Invocation;13import org.jmock.api.InvocationDispatcher;14import org.jmock.internal.StateMachine;15import org.jmock.lib.concurrent.SynchronisingInvocationDispatcherWrapper;16import org.jmock.lib.concurrent.UnsynchronisedInvocationDispatcher;17import org.jmock.test.unit.support.MethodFactory;18import org.jmock.test.unit.support.MockExpectation;19import junit.framework.TestCase;20public class InvocationDispatcherTests extends TestCase {21    // Avoid multi threaeding tests deadlocking22    // Adjust timeout for debugging23    private static final TimeUnit TIMEOUT_UNIT = TimeUnit.SECONDS;24    private static final int TIMEOUT = 2;25    MethodFactory methodFactory = new MethodFactory();26    Invocation invocation = new Invocation(27            "invokedObject",28            methodFactory.newMethod("invokedMethod"),29            Invocation.NO_PARAMETERS);30    static final boolean NOT_RELEVANT = true;31    public void testInvokesFirstMatchingExpectationInGroup() throws Throwable {32        MockExpectation expectation1 = new MockExpectation(false, NOT_RELEVANT, NOT_RELEVANT);33        MockExpectation expectation2 = new MockExpectation(true, NOT_RELEVANT, NOT_RELEVANT);34        MockExpectation expectation3 = new MockExpectation(true, NOT_RELEVANT, NOT_RELEVANT);35        UnsynchronisedInvocationDispatcher dispatcher = new UnsynchronisedInvocationDispatcher();36        dispatcher.add(expectation1);37        dispatcher.add(expectation2);38        dispatcher.add(expectation3);39        expectation1.shouldNotBeInvoked();40        expectation2.shouldBeInvokedWith(invocation);41        expectation3.shouldNotBeInvoked();42        dispatcher.dispatch(invocation);43        assertTrue("expectation2 should have been invoked",44                expectation2.wasInvoked);45    }46    public void testThrowsExpectationErrorIfNoExpectationsMatchAnInvocation() throws Throwable {47        MockExpectation expectation1 = new MockExpectation(false, NOT_RELEVANT, NOT_RELEVANT);48        MockExpectation expectation2 = new MockExpectation(false, NOT_RELEVANT, NOT_RELEVANT);49        MockExpectation expectation3 = new MockExpectation(false, NOT_RELEVANT, NOT_RELEVANT);50        UnsynchronisedInvocationDispatcher dispatcher = new UnsynchronisedInvocationDispatcher();51        dispatcher.add(expectation1);52        dispatcher.add(expectation2);53        dispatcher.add(expectation3);54        expectation1.shouldNotBeInvoked();55        expectation2.shouldNotBeInvoked();56        expectation3.shouldNotBeInvoked();57        try {58            dispatcher.dispatch(invocation);59            fail("should have thrown ExpectationError");60        } catch (ExpectationError e) {61            // expected62        }63    }64    public void testIsSatisfiedOnlyIfAllExpectationsAreSatisfied() {65        UnsynchronisedInvocationDispatcher dispatcherAll = new UnsynchronisedInvocationDispatcher();66        dispatcherAll.add(new MockExpectation(NOT_RELEVANT, true, NOT_RELEVANT));67        dispatcherAll.add(new MockExpectation(NOT_RELEVANT, true, NOT_RELEVANT));68        assertTrue("should be satisfied if all expectations are satisfied",69                dispatcherAll.isSatisfied());70        UnsynchronisedInvocationDispatcher dispatcher1 = new UnsynchronisedInvocationDispatcher();71        dispatcher1.add(new MockExpectation(NOT_RELEVANT, true, NOT_RELEVANT));72        dispatcher1.add(new MockExpectation(NOT_RELEVANT, false, NOT_RELEVANT));73        assertFalse("should not be satisfied if first expectation is not satisfied",74                dispatcher1.isSatisfied());75        UnsynchronisedInvocationDispatcher dispatcher2 = new UnsynchronisedInvocationDispatcher();76        dispatcher2.add(new MockExpectation(NOT_RELEVANT, false, NOT_RELEVANT));77        dispatcher2.add(new MockExpectation(NOT_RELEVANT, true, NOT_RELEVANT));78        assertFalse("should not be satisfied if second expectation is not satisfied",79                dispatcher2.isSatisfied());80        UnsynchronisedInvocationDispatcher dispatcherNone = new UnsynchronisedInvocationDispatcher();81        dispatcherNone.add(new MockExpectation(NOT_RELEVANT, false, NOT_RELEVANT));82        dispatcherNone.add(new MockExpectation(NOT_RELEVANT, true, NOT_RELEVANT));83        assertFalse("should not be satisfied if no expectations are satisfied",84                dispatcherNone.isSatisfied());85    }86    /**87     * Resolves issue 10488     * 89     * @throws Throwable90     */91    public void testUnsynchronisedInvocationDispatcherHandlesAddingExpectationsWhileOtherTestsDispatch()92            throws Throwable {93        final CyclicBarrier barrier = new CyclicBarrier(2);94        MockExpectation expectation1 = new MockExpectation(true, NOT_RELEVANT, NOT_RELEVANT);95        MockExpectation expectation2 = new MockExpectation(false, NOT_RELEVANT, NOT_RELEVANT);96        Collection<Expectation> expectations = new CriticalSectionForcingCollectionWrapper<>(97                new CopyOnWriteArrayList<Expectation>(), barrier);98        Collection<StateMachine> stateMachines = new CriticalSectionForcingCollectionWrapper<>(99                new ArrayList<StateMachine>(), barrier);100        final UnsynchronisedInvocationDispatcher dispatcher = new UnsynchronisedInvocationDispatcher(expectations,101                stateMachines);102        new Thread(new Runnable() {103            @Override104            public void run() {105                try {106                    barrier.await(TIMEOUT, TIMEOUT_UNIT);107                    barrier.await(TIMEOUT, TIMEOUT_UNIT);108                    // now the expectation one has been added109                    dispatcher.dispatch(invocation);110                    barrier.await(TIMEOUT, TIMEOUT_UNIT);111                } catch (Throwable e) {112                    // will throw a ConcurrentModification Exception unless a multithreaded strategy113                    // is used114                    throw new RuntimeException(e);115                }116            }117        }, "Concurrent Dispatch").start();118        // expect dispatch119        dispatcher.add(expectation1);120        // await is satisfied check121        dispatcher.add(expectation2);122        barrier.await(TIMEOUT, TIMEOUT_UNIT);123        expectation1.shouldBeInvokedWith(invocation);124        assertTrue("expectation1 should have been invoked",125                expectation1.wasInvoked);126    }127    public void testSynchronisedInvocationDispatcherBlocksAddingExpectationsWhileOtherTestsDispatch()128            throws Throwable {129        final CyclicBarrier barrier = new CyclicBarrier(2);130        131        MockExpectation expectation1 = new MockExpectation(true, NOT_RELEVANT, NOT_RELEVANT);132        MockExpectation expectation2 = new MockExpectation(false, NOT_RELEVANT, NOT_RELEVANT);133        // intentionally use array list as the wrapper should synchronise access134        final InvocationDispatcher dispatcher = new SynchronisingInvocationDispatcherWrapper(135                new UnsynchronisedInvocationDispatcher(new ArrayList<Expectation>(), new ArrayList<StateMachine>()));136        // expect dispatch137        dispatcher.add(expectation1);138        new Thread(new Runnable() {139            @Override140            public void run() {141                try {142                    dispatcher.dispatch(invocation);143                    barrier.await();144                } catch (Throwable e) {145                    throw new RuntimeException(e);146                }147            }148        }, "Concurrent Dispatch").start();...