Method loadMarkets

java/lib/src/main/java/io/github/ccxt/Exchange.java:1536–1578

(Object... args)

    private final Object marketsLock = new Object();

    public java.util.concurrent.CompletableFuture<Object> loadMarkets(Object... args) {

        var reload = (Boolean) Helpers.getArg(args, 0, false);
        if (this.marketsLoaded && !reload) {
            return this.marketsLoading;
        }
        synchronized (marketsLock) {
            // Re-check under the lock to collapse concurrent first-callers onto the same future.
            if (this.marketsLoaded && !reload) {
                return this.marketsLoading;
            }
            // Collapse concurrent callers onto the same in-flight reload regardless
            // of the reload flag. The previous `|| reload` short-circuit caused 20
            // concurrent loadMarkets(true) callers to spawn 20 sequential fetches.
            // The cache-vs-fetch decision still respects `reload` via the early
            // `marketsLoaded && !reload` guard above; this branch only decides
            // whether to start a *new* fetch when none is in-flight.
            if (!this.reloadingMarkets) {
                this.reloadingMarkets = true;
                try {
                    this.marketsLoading = this.loadMarketsHelper(reload)
                            .thenApply(res -> {
                                synchronized (marketsLock) {
                                    this.reloadingMarkets = false;
                                    this.marketsLoaded = true;
                                }
                                return res;
                            })
                            .exceptionallyCompose(ex -> {
                                synchronized (marketsLock) {
                                    this.reloadingMarkets = false;
                                    this.marketsLoading = null;
                                }
                                return CompletableFuture.failedFuture(ex);
                            });
                } catch (ExecutionException | InterruptedException e) {
                    this.reloadingMarkets = false;
                    throw new RuntimeException(e);
                }
            }
            return this.marketsLoading;
        }
    }

    public CompletableFuture<Object> fetchCurrencies(Object... params) {
        return CompletableFuture.completedFuture(this.currencies);