KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use UnsynchronisedInvocationDispatcher class of org.jmock.lib.concurrent package

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

Source:InvocationDispatcherTests.java

...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();149        // await until dispatch...

Source:PortalSynchroniser.java

...3import org.jmock.api.Invocation;4import org.jmock.api.InvocationDispatcher;5import org.jmock.api.Invokable;6import org.jmock.api.ThreadingPolicy;7import org.jmock.lib.concurrent.UnsynchronisedInvocationDispatcher;8/**9 * Extension to the base JMock synchroniser to support some edge cases10 * with our custom JMock extensions11 * @author Josh Vote (CSIRO)12 *13 */14public class PortalSynchroniser implements ThreadingPolicy {15    private final ReentrantLock lock = new ReentrantLock(true);16    private final InvocationDispatcher dispatcher = new UnsynchronisedInvocationDispatcher();17    18    public Invokable synchroniseAccessTo(final Invokable mockObject) {19        return new Invokable() {20            public Object invoke(Invocation invocation) throws Throwable {21                return synchroniseInvocation(mockObject, invocation);22            }23        };24    }25    /**26     * Acquires (or reacquires) the lock used by this ThreadingPolicy27     * for the current thread. Blocks if the lock cannot be acquired.28     *29     * Ensure that a call to releaseLock is made if acquring locks30     * @throws InterruptedException...

Source:SingleThreadedPolicy.java

...4import org.jmock.api.InvocationDispatcher;5import org.jmock.api.Invokable;6import org.jmock.api.ThreadingPolicy;7import org.jmock.lib.concurrent.Synchroniser;8import org.jmock.lib.concurrent.UnsynchronisedInvocationDispatcher;9public class SingleThreadedPolicy implements ThreadingPolicy {10    private final Thread testThread;11    12    public SingleThreadedPolicy() {13        this.testThread = Thread.currentThread();14    }15    public Invokable synchroniseAccessTo(final Invokable mockObject) {16        return new Invokable() {17            public Object invoke(Invocation invocation) throws Throwable {18                checkRunningOnTestThread();19                return mockObject.invoke(invocation);20            }21        };22    }23    24    private void checkRunningOnTestThread() {25        if (Thread.currentThread() != testThread) {26            reportError("the Mockery is not thread-safe: use a " + 27                        Synchroniser.class.getSimpleName() + " to ensure thread safety");28        }29    }30    31    private void reportError(String error) {32        System.err.println(error);33        throw new ConcurrentModificationException(error);34    }35    public InvocationDispatcher dispatcher() {36        return new UnsynchronisedInvocationDispatcher();37    }38}...