public Future execute()

in archaius2-core/src/main/java/com/netflix/archaius/config/polling/ManualPollingStrategy.java [45:65]

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

    public Future<?> execute(final Runnable run) {
        return executor.submit(new Runnable() {
            @Override
            public void run() {
                Request request;
                try {
                    while (null != (request = queue.take())) {
                        try {
                            run.run();
                        } catch (Exception e) {
                            request.error = e;
                        } finally {
                            request.latch.countDown();
                        }
                    }
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }
        });
    }