}

    public Future<ProjectSegment> submit(Callable<ProjectSegment> task) {
        FutureTask<ProjectSegment> projectBuildFutureTask = new FutureTask<>(task);
        projectBuildFutureTasks.add(projectBuildFutureTask);
        if (finishImmediately) {
            projectBuildFutureTask.run();
        }
        return projectBuildFutureTask;
    }

    public Future<ProjectSegment> submit(Runnable task, ProjectSegment result) {

                    // we are already visiting this vertex, this mean we have a cycle
                    int pos = cycle.lastIndexOf(v);
                    List<String> ret = cycle.subList(pos, cycle.size());
                    ret.add(v);
                    return ret;
                }
            }
        }
        return null;
    }

            } else if (state == DfsState.VISITING) {
                // we are already visiting this vertex, this mean we have a cycle
                int pos = cycle.lastIndexOf(v.label);
                List<String> ret = cycle.subList(pos, cycle.size());
                ret.add(v.label);
                return ret;
            }
        }
        return null;
    }

    static class Vertex {
        final String label;

            Callable<ProjectSegment> cb = createBuildCallable(
                    rootSession, projectSegment, reactorContext, taskSegment, muxer, duplicateArtifactIds);
            service.submit(cb);
        }

        // for each finished project
        for (int i = 0; i < analyzer.getNumberOfBuilds(); i++) {
            try {
                ProjectSegment projectBuild = service.take().get();

        List<Future<ProjectSegment>> futures = new ArrayList<>();
        for (ProjectSegment projectBuild : projectBuildList) {
            final Future<ProjectSegment> buildFuture =
                    service.submit(new Outputter(threadOutputMuxer, projectBuild, lyrics.next()));
            futures.add(buildFuture);
        }

        for (Future<ProjectSegment> future : futures) {
            future.get();
        }

            } else if (state == DfsState.VISITING) {
                // we are already visiting this vertex, this mean we have a cycle
                int pos = cycle.lastIndexOf(v.label);
                List<String> ret = cycle.subList(pos, cycle.size());
                ret.add(v.label);
                return ret;
            }
        }
        return null;
    }

    static class Vertex {
        final String label;