Method getAsync

src/main/java/groovy/concurrent/Agent.java:150–161

Returns the current value as an Awaitable. The awaitable completes after all previously queued updates have been applied, ensuring a consistent read. @return an awaitable holding the value after pending updates

()

     * @return an awaitable holding the value after pending updates
     */
    public Awaitable<T> getAsync() {
        CompletableFuture<T> cf = new CompletableFuture<>();
        updateExecutor.execute(() -> {
            rwLock.readLock().lock();
            try {
                cf.complete(value);
            } finally {
                rwLock.readLock().unlock();
            }
        });
        return GroovyPromise.of(cf);
    }

    /**
     * Queues an update function to be applied to the current value.