public static Collection provideAllForkJoinTasks()

in disco-java-agent/disco-java-agent-core/src/integ/java/software/amazon/disco/agent/integtest/concurrent/source/TestForkJoinTaskFactory.java [164:193]

• 23 lines of code
• 4 McCabe index (conditional complexity)

        public static Collection<Object[]> provideAllForkJoinTasks() {
            List<Object[]> runnableData = TestRunnableFactory.Data.provideAllRunnables();
            List<Object[]> runnableDataWithResult = TestRunnableFactory.Data.provideAllRunnables();
            List<Object[]> callableData = TestCallableFactory.Data.provideAllCallables();

            List<Object[]> result = new ArrayList<>(numFactoryMethods);
            int i = 0;

            int j = 0;
            for (Object[] tuple: runnableData) {
                TestRunnableFactory.TestableRunnable runnable = TestRunnableFactory.TestableRunnable.class.cast(tuple[1]);
                result.add(i++, new Object[] {"ForkJoinTaskAdaptedFromRunnable-"+runnableData.get(j++)[0], new NonThrowingTestableForkJoinTask(ForkJoinTask.adapt(runnable.getRunnable()), runnable)});
            }

            j = 0;
            for (Object[] tuple: runnableDataWithResult) {
                TestRunnableFactory.TestableRunnable runnable = TestRunnableFactory.TestableRunnable.class.cast(tuple[1]);
                result.add(i++, new Object[] {"ForkJoinTaskAdaptedFromRunnableWithResult-"+runnableData.get(j++)[0], new NonThrowingTestableForkJoinTask(ForkJoinTask.adapt(runnable.getRunnable()), runnable)});
            }

            j = 0;
            for (Object[] tuple: callableData) {
                TestCallableFactory.NonThrowingTestableCallable callable = TestCallableFactory.NonThrowingTestableCallable.class.cast(tuple[1]);
                result.add(i++, new Object[] {"ForkJoinTaskAdaptedFromCallable-"+runnableData.get(j++)[0], new NonThrowingTestableForkJoinTask(ForkJoinTask.adapt(callable.callable), callable)});
            }

            //result[i++] = new Object[] {"AnonymousRecursiveTask", createAnonymousRecursiveTask()};

            return result;
        }