doTestParseResolverFilesAllowsBlockingCalls() — netty Function Reference

Source Code

transport-blockhound-tests/src/test/java/io/netty/util/internal/NettyBlockHoundIntegrationTest.java lines 423–455

    private static void doTestParseResolverFilesAllowsBlockingCalls(Callable<Object> callable)
            throws InterruptedException {
        SingleThreadEventExecutor executor =
                new SingleThreadEventExecutor(null, new DefaultThreadFactory("test"), true) {
                    @Override
                    protected void run() {
                        while (!confirmShutdown()) {
                            Runnable task = takeTask();
                            if (task != null) {
                                task.run();
                            }
                        }
                    }
                };
        try {
            CountDownLatch latch = new CountDownLatch(1);
            List<Object> result = new ArrayList<>();
            List<Throwable> error = new ArrayList<>();
            executor.execute(() -> {
                try {
                    result.add(callable.call());
                } catch (Throwable t) {
                    error.add(t);
                }
                latch.countDown();
            });
            latch.await();
            assertEquals(0, error.size());
            assertEquals(1, result.size());
        } finally {
            executor.shutdownGracefully();
        }
    }