Bulkhead.java

@Test
    void threadPoolBulkhead() throws InterruptedException {
        //Only 5 Threads will be the hability to execute a code
        ThreadPoolBulkhead threadPoolBulkhead = ThreadPoolBulkhead.of("threads", ThreadPoolBulkheadConfig.custom()
                .coreThreadPoolSize(5)
                .maxThreadPoolSize(5)
                .build());

        //Decorating the execution of the method and the configuration of the threadPool
        Supplier<CompletionStage<Void>> withBulkhead = ThreadPoolBulkhead.decorateRunnable(threadPoolBulkhead, this::takeBook);

        //Creating a new ExecutorService
        ExecutorService service = Executors.newFixedThreadPool(NUMBER_OF_PEOPLE);

        //Wrapping the execution of the bulkhead inside  a task
        Runnable task = () -> {
            log.info("Try to get a book");
            Try.ofSupplier(withBulkhead);
        };

        //Creating N threads to execute the task
        List<Callable<Object>> tasks = Stream.continually(task)
                .map(Executors::callable)
                .take(NUMBER_OF_BOOKS).toJavaList();

        //Running all the threads
        service.invokeAll(tasks, 500, TimeUnit.MILLISECONDS);
    }

    @Test
    void semaphore() throws InterruptedException {
        Bulkhead bulkhead = Bulkhead.of("semaphore", BulkheadConfig.custom()
                .maxConcurrentCalls(NUMBER_OF_BOOKS)
                .build());
        Runnable withBulkhead = Bulkhead.decorateRunnable(bulkhead, this::takeBook);

        this.captureEvents(bulkhead.getEventPublisher());

        everybodyInTheLibrary(withBulkhead);
    }