KaneAI - World’s First E2E Software Testing Agent.Book a Demo Join TestMu Conference

How to use checkIncompatibleMultiThreading method of com.tngtech.jgiven.testng.IncompatibleMultithreadingChecker class

Best JGiven code snippet using com.tngtech.jgiven.testng.IncompatibleMultithreadingChecker.checkIncompatibleMultiThreading

Source:ScenarioTestListener.java

...37        ReportModel reportModel = getReportModel(paramITestResult, instance.getClass());38        scenario.setModel(reportModel);39        //TestNG cannot run in parallel if stages are to be injected, because then multiple scenarios40        //will attempt to inject into a single test instance at the same time.41        new IncompatibleMultithreadingChecker().checkIncompatibleMultiThreading(paramITestResult);42        // TestNG does not work well when catching step exceptions, so we have to disable that feature43        // this mainly means that steps following a failing step are not reported in JGiven44        scenario.getExecutor().setSuppressStepExceptions(false);45        // avoid rethrowing exceptions as they are already thrown by the steps46        scenario.getExecutor().setSuppressExceptions(true);47        scenario.getExecutor().injectStages(instance);48        Method method = paramITestResult.getMethod().getConstructorOrMethod().getMethod();49        scenario.startScenario(instance.getClass(), method, getArgumentsFrom(method, paramITestResult));50        // inject state from the test itself51        scenario.getExecutor().readScenarioState(instance);52    }53    private ScenarioBase getScenario(ITestResult paramITestResult) {54        return (ScenarioBase) paramITestResult.getAttribute(SCENARIO_ATTRIBUTE);55    }...

Source:IncompatibleMultiThreadingCheckerTest.java

...21            public void multithreadedTest() {22            }23        }24        ITestResult testInput = mockInput(MultiThreadedInjectedTestClass.class, "multithreadedTest");25        assertThatCode(() -> underTest.checkIncompatibleMultiThreading(testInput))26            .isInstanceOf(JGivenWrongUsageException.class);27    }28    @Test29    public void testNoErrorThrownIfSingleThreaded() throws NoSuchMethodException {30        @Test(singleThreaded = true)31        class SingleThreadedInjectedTestClass {32            @ScenarioStage33            private String injected;34            @Test(enabled = false)35            public void singleThreadedTest() {36            }37        }38        ITestResult testInput = mockInput(SingleThreadedInjectedTestClass.class, "singleThreadedTest");39        assertThatCode(() -> underTest.checkIncompatibleMultiThreading(testInput))40            .doesNotThrowAnyException();41    }42    @Test43    public void testNoErrorThrownIfNoInjectedStages() throws NoSuchMethodException {44        @Test(singleThreaded = false, enabled = false)45        class MultiThreadedTestClass {46            public void test() {47            }48        }49        ITestResult testInput = mockInput(MultiThreadedTestClass.class, "test");50        assertThatCode(() -> underTest.checkIncompatibleMultiThreading(testInput))51            .doesNotThrowAnyException();52    }53    private ITestResult mockInput(Class<?> testClass, String methodName) throws NoSuchMethodException {54        ITestResult testInput = mock(ITestResult.class, RETURNS_DEEP_STUBS);55        when(testInput.getTestClass().getRealClass()).then(invocation -> testClass);56        when(testInput.getMethod().getConstructorOrMethod().getMethod()).thenReturn(testClass.getMethod(methodName));57        return testInput;58    }59}...

Source:IncompatibleMultithreadingChecker.java

...7import org.testng.ITestResult;8import org.testng.annotations.Test;9class IncompatibleMultithreadingChecker {10    @SuppressWarnings("checkstyle:AbbreviationAsWordInName")11    public void checkIncompatibleMultiThreading(ITestResult paramITestResult) {12        boolean isMultiThreaded = isMultiThreaded(paramITestResult.getTestClass().getRealClass());13        boolean hasInjectedStages = hasInjectedStages(paramITestResult.getTestClass().getRealClass());14        if (isMultiThreaded && hasInjectedStages) {15            throw new JGivenWrongUsageException("JGiven does not support using multi-threading and stage injection "16                + "in TestNG at the same time due to their different lifecycle models. "17                + "Please switch to single threaded execution or provide stages via inheriting from ScenarioTest");18        }19    }20    private boolean isMultiThreaded(Class<?> testClass) {21        return Optional.ofNullable(testClass.getAnnotation(Test.class))22            .map(test -> !test.singleThreaded())23            .orElse(false);24    }25    private boolean hasInjectedStages(Class<?> testClass) {...