<del id="muuyu"></del>

<strike id="muuyu"></strike>

使用SimpleTimeLimiter進行方法調用超時控制

zhonghanwen 發布于2019-08-14 15:28 / 860人閱讀

原理

利用Executors的Future的限時get方法，Google的SimpleTimeLimiter本質上是對Executors的Future的包裝。

實例

package com.facebook.presto.raptor.backup;

import com.facebook.presto.spi.PrestoException;
import com.google.common.util.concurrent.SimpleTimeLimiter;
import com.google.common.util.concurrent.TimeLimiter;
import com.google.common.util.concurrent.UncheckedTimeoutException;
import io.airlift.units.Duration;

import javax.annotation.PreDestroy;

import java.io.File;
import java.util.OptionalLong;
import java.util.UUID;
import java.util.concurrent.ExecutorService;

import static com.facebook.presto.raptor.RaptorErrorCode.RAPTOR_BACKUP_TIMEOUT;
import static io.airlift.concurrent.Threads.daemonThreadsNamed;
import static java.util.Objects.requireNonNull;
import static java.util.concurrent.Executors.newCachedThreadPool;
import static java.util.concurrent.TimeUnit.MILLISECONDS;

public class TimeoutBackupStore
        implements BackupStore
{
    private final ExecutorService executor;
    private final BackupStore store;

    public TimeoutBackupStore(BackupStore store, String connectorId, Duration timeout)
    {
        requireNonNull(store, "store is null");
        requireNonNull(connectorId, "connectorId is null");
        requireNonNull(timeout, "timeout is null");
        this.executor = newCachedThreadPool(daemonThreadsNamed("backup-proxy-" + connectorId + "-%s"));
        this.store = timeLimited(store, BackupStore.class, timeout, executor);
    }

    @PreDestroy
    public void shutdown()
    {
        executor.shutdownNow();
    }

    @Override
    public void backupShard(UUID uuid, File source)
    {
        try {
            store.backupShard(uuid, source);
        }
        catch (UncheckedTimeoutException e) {
            throw new PrestoException(RAPTOR_BACKUP_TIMEOUT, "Shard backup timed out");
        }
    }

    @Override
    public void restoreShard(UUID uuid, File target)
    {
        try {
            store.restoreShard(uuid, target);
        }
        catch (UncheckedTimeoutException e) {
            throw new PrestoException(RAPTOR_BACKUP_TIMEOUT, "Shard restore timed out");
        }
    }

    @Override
    public OptionalLong shardSize(UUID uuid)
    {
        try {
            return store.shardSize(uuid);
        }
        catch (UncheckedTimeoutException e) {
            throw new PrestoException(RAPTOR_BACKUP_TIMEOUT, "Shard backup size fetch timed out");
        }
    }

    private static  T timeLimited(T target, Class clazz, Duration timeout, ExecutorService executor)
    {
        TimeLimiter limiter = new SimpleTimeLimiter(executor);
        return limiter.newProxy(target, clazz, timeout.toMillis(), MILLISECONDS);
    }
}

參考

SimpleTimeLimiterShowcase

TimeoutBackupStore

云服務器 GPU云服務器控制器使用方法控制函數調用 SimpleTimeLimiter 方法調用

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/65786.html

Dubbo 源碼分析20 Dubbo服務提供者、服務消費者并發度控制機制

摘要：代碼根據服務提供者和服務調用方法名，獲取。代碼根據服務提供者配置的最大并發度，創建該服務該方法對應的信號量對象。總結是控制消費端對單個服務提供者單個服務允許調用的最大并發度。本文將詳細分析< dubbo:service executes=/>與< dubbo:reference actives = />的實現機制，深入探...

不知名網友 2021-11-29 10:50 評論0 收藏0
分布式熔斷降級平臺aegis

摘要：現狀分布式場景中。因此要對在原服務不可用時進行熔斷降級處理。分析熔斷降級可以服務端限流網關限流客戶端限流。它提供兩種資源隔離的模式信號量隔離和線程池隔離。支持流控熔斷降級系統保護等。它支持并發數的流量控制也支持熔斷降級。現狀分布式場景中。若服務不穩定，會導致調用方服務也不可用，從而造成雪崩效應。因此要對在原服務不可用時進行熔斷降級處理。分析熔斷降級可以服務端限流、網關限流、客戶...

ixlei 2019-08-16 15:24 評論0 收藏0
手撕ThreadPoolExecutor線程池源碼

摘要：所以，在時執行也是為了保證線程池在狀態下必須要有一個線程來執行任務。這篇文章對ThreadPoolExecutor創建的線程池如何操作線程的生命周期通過源碼的方式進行詳細解析。通過對execute方法、addWorker方法、Worker類、runWorker方法、getTask方法、processWorkerExit從源碼角度詳細闡述，文末有彩蛋。 exexcte方法 public...

Corwien 2019-08-19 10:35 評論0 收藏0
HttpInterceptor 攔截器 - 網絡請求超時與重試的簡單實現

摘要：對象表示攔截器鏈表中的下一個攔截器。至此，攔截器只會再重試到最大次數還是失敗的情況下拋出超時錯誤。完成上述步驟，一個簡單的網絡請求超時與重試的攔截器便實現了。 ... 攔截器在Angular項目中其實有著十分重要的地位，攔截器可以統一對 HTTP 請求進行攔截處理，我們可以在每個請求體或者響應后對應的流添加一系列動作或者處理數據，再返回給使用者調用。每個 API 調用的時候都不可避免...

stonezhu 2019-08-23 12:31 評論0 收藏0