实例介绍
【实例简介】
failsafe:Fault tolerance and resilience patterns for the JVM源码下载
【实例截图】
【核心代码】
文件清单
└── failsafe-ceb14ace0c665a7a7fef1d0440c14d7122423343
├── bin
│ └── push-javadoc.sh
├── CHANGELOG.md
├── CONTRIBUTING.md
├── core
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── dev
│ │ │ └── failsafe
│ │ │ ├── AsyncExecutionImpl.java
│ │ │ ├── AsyncExecution.java
│ │ │ ├── BulkheadBuilder.java
│ │ │ ├── BulkheadConfig.java
│ │ │ ├── BulkheadFullException.java
│ │ │ ├── Bulkhead.java
│ │ │ ├── CallImpl.java
│ │ │ ├── Call.java
│ │ │ ├── CircuitBreakerBuilder.java
│ │ │ ├── CircuitBreakerConfig.java
│ │ │ ├── CircuitBreaker.java
│ │ │ ├── CircuitBreakerOpenException.java
│ │ │ ├── DelayablePolicyBuilder.java
│ │ │ ├── DelayablePolicyConfig.java
│ │ │ ├── event
│ │ │ │ ├── CircuitBreakerStateChangedEvent.java
│ │ │ │ ├── EventListener.java
│ │ │ │ ├── ExecutionAttemptedEvent.java
│ │ │ │ ├── ExecutionCompletedEvent.java
│ │ │ │ ├── ExecutionEvent.java
│ │ │ │ ├── ExecutionScheduledEvent.java
│ │ │ │ └── package-info.java
│ │ │ ├── ExecutionContext.java
│ │ │ ├── ExecutionImpl.java
│ │ │ ├── Execution.java
│ │ │ ├── FailsafeException.java
│ │ │ ├── FailsafeExecutor.java
│ │ │ ├── Failsafe.java
│ │ │ ├── FailurePolicyBuilder.java
│ │ │ ├── FailurePolicyConfig.java
│ │ │ ├── FallbackBuilder.java
│ │ │ ├── FallbackConfig.java
│ │ │ ├── Fallback.java
│ │ │ ├── function
│ │ │ │ ├── AsyncRunnable.java
│ │ │ │ ├── AsyncSupplier.java
│ │ │ │ ├── CheckedBiPredicate.java
│ │ │ │ ├── CheckedConsumer.java
│ │ │ │ ├── CheckedFunction.java
│ │ │ │ ├── CheckedPredicate.java
│ │ │ │ ├── CheckedRunnable.java
│ │ │ │ ├── CheckedSupplier.java
│ │ │ │ ├── ContextualRunnable.java
│ │ │ │ ├── ContextualSupplier.java
│ │ │ │ └── package-info.java
│ │ │ ├── Functions.java
│ │ │ ├── internal
│ │ │ │ ├── BulkheadExecutor.java
│ │ │ │ ├── BulkheadImpl.java
│ │ │ │ ├── BurstyRateLimiterStats.java
│ │ │ │ ├── CircuitBreakerExecutor.java
│ │ │ │ ├── CircuitBreakerImpl.java
│ │ │ │ ├── CircuitState.java
│ │ │ │ ├── CircuitStats.java
│ │ │ │ ├── ClosedState.java
│ │ │ │ ├── CountingCircuitStats.java
│ │ │ │ ├── DefaultCircuitStats.java
│ │ │ │ ├── EventHandler.java
│ │ │ │ ├── FallbackExecutor.java
│ │ │ │ ├── FallbackImpl.java
│ │ │ │ ├── HalfOpenState.java
│ │ │ │ ├── OpenState.java
│ │ │ │ ├── RateLimiterExecutor.java
│ │ │ │ ├── RateLimiterImpl.java
│ │ │ │ ├── RateLimiterStats.java
│ │ │ │ ├── RetryPolicyExecutor.java
│ │ │ │ ├── RetryPolicyImpl.java
│ │ │ │ ├── SmoothRateLimiterStats.java
│ │ │ │ ├── TimedCircuitStats.java
│ │ │ │ ├── TimeoutExecutor.java
│ │ │ │ ├── TimeoutImpl.java
│ │ │ │ └── util
│ │ │ │ ├── Assert.java
│ │ │ │ ├── DelegatingScheduler.java
│ │ │ │ ├── Durations.java
│ │ │ │ ├── FutureLinkedList.java
│ │ │ │ ├── Lists.java
│ │ │ │ ├── Maths.java
│ │ │ │ └── RandomDelay.java
│ │ │ ├── package-info.java
│ │ │ ├── PolicyBuilder.java
│ │ │ ├── PolicyConfig.java
│ │ │ ├── Policy.java
│ │ │ ├── PolicyListeners.java
│ │ │ ├── RateLimiterBuilder.java
│ │ │ ├── RateLimiterConfig.java
│ │ │ ├── RateLimiter.java
│ │ │ ├── RateLimitExceededException.java
│ │ │ ├── RetryPolicyBuilder.java
│ │ │ ├── RetryPolicyConfig.java
│ │ │ ├── RetryPolicy.java
│ │ │ ├── spi
│ │ │ │ ├── AsyncExecutionInternal.java
│ │ │ │ ├── DefaultScheduledFuture.java
│ │ │ │ ├── DelayablePolicy.java
│ │ │ │ ├── ExecutionInternal.java
│ │ │ │ ├── ExecutionResult.java
│ │ │ │ ├── FailsafeFuture.java
│ │ │ │ ├── FailurePolicy.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── PolicyExecutor.java
│ │ │ │ ├── Scheduler.java
│ │ │ │ └── SyncExecutionInternal.java
│ │ │ ├── SyncExecutionImpl.java
│ │ │ ├── TimeoutBuilder.java
│ │ │ ├── TimeoutConfig.java
│ │ │ ├── TimeoutExceededException.java
│ │ │ └── Timeout.java
│ │ └── javadoc
│ │ └── overview.html
│ └── test
│ └── java
│ └── dev
│ └── failsafe
│ ├── AsyncExecutionTest.java
│ ├── AsyncFailsafeTest.java
│ ├── BulkheadBuilderTest.java
│ ├── CircuitBreakerBuilderTest.java
│ ├── CircuitBreakerTest.java
│ ├── DelayablePolicyTest.java
│ ├── ExecutionTest.java
│ ├── FailsafeFutureTest.java
│ ├── FailsafeTest.java
│ ├── FailurePolicyBuilderTest.java
│ ├── FailurePolicyTest.java
│ ├── FallbackBuilderTest.java
│ ├── functional
│ │ ├── BlockedExecutionTest.java
│ │ ├── BulkheadTest.java
│ │ ├── CallCancellationTest.java
│ │ ├── CircuitBreakerTest.java
│ │ ├── DelayableCircuitBreakerTest.java
│ │ ├── DelayableRetryPolicyTest.java
│ │ ├── ExecutorConfigurationTest.java
│ │ ├── ExecutorTest.java
│ │ ├── FallbackTest.java
│ │ ├── FutureCancellationTest.java
│ │ ├── FutureCompletionTest.java
│ │ ├── InterruptionTest.java
│ │ ├── NestedCircuitBreakerTest.java
│ │ ├── NestedRetryPolicyTest.java
│ │ ├── NestedTimeoutTest.java
│ │ ├── NoPolicyTest.java
│ │ ├── package-info.java
│ │ ├── PolicyCompositionExecutionTest.java
│ │ ├── PolicyCompositionTest.java
│ │ ├── RateLimiterTest.java
│ │ ├── RetryPolicyTest.java
│ │ ├── ShutdownExecutorTest.java
│ │ └── TimeoutTest.java
│ ├── internal
│ │ ├── BurstyRateLimiterStatsTest.java
│ │ ├── CircuitStatsTest.java
│ │ ├── ClosedStateTest.java
│ │ ├── CountingCircuitStatsTest.java
│ │ ├── HalfOpenStateTest.java
│ │ ├── InternalTesting.java
│ │ ├── OpenStateTest.java
│ │ ├── RateLimiterImplTest.java
│ │ ├── RateLimiterStatsTest.java
│ │ ├── RetryPolicyImplTest.java
│ │ ├── SmoothRateLimiterStatsTest.java
│ │ ├── TimedCircuitStatsTest.java
│ │ └── util
│ │ ├── DelegatingSchedulerTest.java
│ │ ├── DurationsTest.java
│ │ ├── FutureLinkedListTest.java
│ │ ├── ListsTest.java
│ │ ├── MathsTest.java
│ │ └── RandomDelayTest.java
│ ├── issues
│ │ ├── Issue115Test.java
│ │ ├── Issue131Test.java
│ │ ├── Issue146Test.java
│ │ ├── Issue165Test.java
│ │ ├── Issue177Test.java
│ │ ├── Issue190Test.java
│ │ ├── Issue192Test.java
│ │ ├── Issue206Test.java
│ │ ├── Issue215Test.java
│ │ ├── Issue218Test.java
│ │ ├── Issue224Test.java
│ │ ├── Issue231Test.java
│ │ ├── Issue240Test.java
│ │ ├── Issue242Test.java
│ │ ├── Issue260Test.java
│ │ ├── Issue267Test.java
│ │ ├── Issue284Test.java
│ │ ├── Issue298Test.java
│ │ ├── Issue311Test.java
│ │ ├── Issue36Test.java
│ │ ├── Issue52Test.java
│ │ ├── Issue55Test.java
│ │ ├── Issue5Test.java
│ │ ├── Issue75Test.java
│ │ ├── Issue76Test.java
│ │ ├── Issue84Test.java
│ │ └── Issue9Test.java
│ ├── ListenersTest.java
│ ├── RateLimiterBuilderTest.java
│ ├── RetryPolicyBuilderTest.java
│ ├── testing
│ │ ├── Asserts.java
│ │ ├── Logging.java
│ │ ├── Mocking.java
│ │ ├── package-info.java
│ │ ├── TestCaseLogger.java
│ │ └── Testing.java
│ └── TimeoutBuilderTest.java
├── examples
│ ├── pom.xml
│ └── src
│ └── main
│ └── java
│ └── dev
│ └── failsafe
│ └── examples
│ ├── AsyncExample.java
│ ├── Java8Example.java
│ ├── NettyExample.java
│ ├── RetryLoopExample.java
│ ├── RxJavaExample.java
│ └── VertxExample.java
├── LICENSE
├── modules
│ ├── okhttp
│ │ ├── pom.xml
│ │ └── src
│ │ ├── main
│ │ │ └── java
│ │ │ └── dev
│ │ │ └── failsafe
│ │ │ └── okhttp
│ │ │ └── FailsafeCall.java
│ │ └── test
│ │ └── java
│ │ └── dev
│ │ └── failsafe
│ │ └── okhttp
│ │ ├── FailsafeCallTest.java
│ │ └── testing
│ │ └── OkHttpTesting.java
│ └── retrofit
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── dev
│ │ └── failsafe
│ │ └── retrofit
│ │ └── FailsafeCall.java
│ └── test
│ └── java
│ └── dev
│ └── retrofit
│ ├── FailsafeCallTest.java
│ ├── testing
│ │ └── RetrofitTesting.java
│ └── TestService.java
├── pom.xml
├── README.md
└── VERSIONING.md
56 directories, 218 files
failsafe:Fault tolerance and resilience patterns for the JVM源码下载
【实例截图】
【核心代码】
文件清单
└── failsafe-ceb14ace0c665a7a7fef1d0440c14d7122423343
├── bin
│ └── push-javadoc.sh
├── CHANGELOG.md
├── CONTRIBUTING.md
├── core
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── dev
│ │ │ └── failsafe
│ │ │ ├── AsyncExecutionImpl.java
│ │ │ ├── AsyncExecution.java
│ │ │ ├── BulkheadBuilder.java
│ │ │ ├── BulkheadConfig.java
│ │ │ ├── BulkheadFullException.java
│ │ │ ├── Bulkhead.java
│ │ │ ├── CallImpl.java
│ │ │ ├── Call.java
│ │ │ ├── CircuitBreakerBuilder.java
│ │ │ ├── CircuitBreakerConfig.java
│ │ │ ├── CircuitBreaker.java
│ │ │ ├── CircuitBreakerOpenException.java
│ │ │ ├── DelayablePolicyBuilder.java
│ │ │ ├── DelayablePolicyConfig.java
│ │ │ ├── event
│ │ │ │ ├── CircuitBreakerStateChangedEvent.java
│ │ │ │ ├── EventListener.java
│ │ │ │ ├── ExecutionAttemptedEvent.java
│ │ │ │ ├── ExecutionCompletedEvent.java
│ │ │ │ ├── ExecutionEvent.java
│ │ │ │ ├── ExecutionScheduledEvent.java
│ │ │ │ └── package-info.java
│ │ │ ├── ExecutionContext.java
│ │ │ ├── ExecutionImpl.java
│ │ │ ├── Execution.java
│ │ │ ├── FailsafeException.java
│ │ │ ├── FailsafeExecutor.java
│ │ │ ├── Failsafe.java
│ │ │ ├── FailurePolicyBuilder.java
│ │ │ ├── FailurePolicyConfig.java
│ │ │ ├── FallbackBuilder.java
│ │ │ ├── FallbackConfig.java
│ │ │ ├── Fallback.java
│ │ │ ├── function
│ │ │ │ ├── AsyncRunnable.java
│ │ │ │ ├── AsyncSupplier.java
│ │ │ │ ├── CheckedBiPredicate.java
│ │ │ │ ├── CheckedConsumer.java
│ │ │ │ ├── CheckedFunction.java
│ │ │ │ ├── CheckedPredicate.java
│ │ │ │ ├── CheckedRunnable.java
│ │ │ │ ├── CheckedSupplier.java
│ │ │ │ ├── ContextualRunnable.java
│ │ │ │ ├── ContextualSupplier.java
│ │ │ │ └── package-info.java
│ │ │ ├── Functions.java
│ │ │ ├── internal
│ │ │ │ ├── BulkheadExecutor.java
│ │ │ │ ├── BulkheadImpl.java
│ │ │ │ ├── BurstyRateLimiterStats.java
│ │ │ │ ├── CircuitBreakerExecutor.java
│ │ │ │ ├── CircuitBreakerImpl.java
│ │ │ │ ├── CircuitState.java
│ │ │ │ ├── CircuitStats.java
│ │ │ │ ├── ClosedState.java
│ │ │ │ ├── CountingCircuitStats.java
│ │ │ │ ├── DefaultCircuitStats.java
│ │ │ │ ├── EventHandler.java
│ │ │ │ ├── FallbackExecutor.java
│ │ │ │ ├── FallbackImpl.java
│ │ │ │ ├── HalfOpenState.java
│ │ │ │ ├── OpenState.java
│ │ │ │ ├── RateLimiterExecutor.java
│ │ │ │ ├── RateLimiterImpl.java
│ │ │ │ ├── RateLimiterStats.java
│ │ │ │ ├── RetryPolicyExecutor.java
│ │ │ │ ├── RetryPolicyImpl.java
│ │ │ │ ├── SmoothRateLimiterStats.java
│ │ │ │ ├── TimedCircuitStats.java
│ │ │ │ ├── TimeoutExecutor.java
│ │ │ │ ├── TimeoutImpl.java
│ │ │ │ └── util
│ │ │ │ ├── Assert.java
│ │ │ │ ├── DelegatingScheduler.java
│ │ │ │ ├── Durations.java
│ │ │ │ ├── FutureLinkedList.java
│ │ │ │ ├── Lists.java
│ │ │ │ ├── Maths.java
│ │ │ │ └── RandomDelay.java
│ │ │ ├── package-info.java
│ │ │ ├── PolicyBuilder.java
│ │ │ ├── PolicyConfig.java
│ │ │ ├── Policy.java
│ │ │ ├── PolicyListeners.java
│ │ │ ├── RateLimiterBuilder.java
│ │ │ ├── RateLimiterConfig.java
│ │ │ ├── RateLimiter.java
│ │ │ ├── RateLimitExceededException.java
│ │ │ ├── RetryPolicyBuilder.java
│ │ │ ├── RetryPolicyConfig.java
│ │ │ ├── RetryPolicy.java
│ │ │ ├── spi
│ │ │ │ ├── AsyncExecutionInternal.java
│ │ │ │ ├── DefaultScheduledFuture.java
│ │ │ │ ├── DelayablePolicy.java
│ │ │ │ ├── ExecutionInternal.java
│ │ │ │ ├── ExecutionResult.java
│ │ │ │ ├── FailsafeFuture.java
│ │ │ │ ├── FailurePolicy.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── PolicyExecutor.java
│ │ │ │ ├── Scheduler.java
│ │ │ │ └── SyncExecutionInternal.java
│ │ │ ├── SyncExecutionImpl.java
│ │ │ ├── TimeoutBuilder.java
│ │ │ ├── TimeoutConfig.java
│ │ │ ├── TimeoutExceededException.java
│ │ │ └── Timeout.java
│ │ └── javadoc
│ │ └── overview.html
│ └── test
│ └── java
│ └── dev
│ └── failsafe
│ ├── AsyncExecutionTest.java
│ ├── AsyncFailsafeTest.java
│ ├── BulkheadBuilderTest.java
│ ├── CircuitBreakerBuilderTest.java
│ ├── CircuitBreakerTest.java
│ ├── DelayablePolicyTest.java
│ ├── ExecutionTest.java
│ ├── FailsafeFutureTest.java
│ ├── FailsafeTest.java
│ ├── FailurePolicyBuilderTest.java
│ ├── FailurePolicyTest.java
│ ├── FallbackBuilderTest.java
│ ├── functional
│ │ ├── BlockedExecutionTest.java
│ │ ├── BulkheadTest.java
│ │ ├── CallCancellationTest.java
│ │ ├── CircuitBreakerTest.java
│ │ ├── DelayableCircuitBreakerTest.java
│ │ ├── DelayableRetryPolicyTest.java
│ │ ├── ExecutorConfigurationTest.java
│ │ ├── ExecutorTest.java
│ │ ├── FallbackTest.java
│ │ ├── FutureCancellationTest.java
│ │ ├── FutureCompletionTest.java
│ │ ├── InterruptionTest.java
│ │ ├── NestedCircuitBreakerTest.java
│ │ ├── NestedRetryPolicyTest.java
│ │ ├── NestedTimeoutTest.java
│ │ ├── NoPolicyTest.java
│ │ ├── package-info.java
│ │ ├── PolicyCompositionExecutionTest.java
│ │ ├── PolicyCompositionTest.java
│ │ ├── RateLimiterTest.java
│ │ ├── RetryPolicyTest.java
│ │ ├── ShutdownExecutorTest.java
│ │ └── TimeoutTest.java
│ ├── internal
│ │ ├── BurstyRateLimiterStatsTest.java
│ │ ├── CircuitStatsTest.java
│ │ ├── ClosedStateTest.java
│ │ ├── CountingCircuitStatsTest.java
│ │ ├── HalfOpenStateTest.java
│ │ ├── InternalTesting.java
│ │ ├── OpenStateTest.java
│ │ ├── RateLimiterImplTest.java
│ │ ├── RateLimiterStatsTest.java
│ │ ├── RetryPolicyImplTest.java
│ │ ├── SmoothRateLimiterStatsTest.java
│ │ ├── TimedCircuitStatsTest.java
│ │ └── util
│ │ ├── DelegatingSchedulerTest.java
│ │ ├── DurationsTest.java
│ │ ├── FutureLinkedListTest.java
│ │ ├── ListsTest.java
│ │ ├── MathsTest.java
│ │ └── RandomDelayTest.java
│ ├── issues
│ │ ├── Issue115Test.java
│ │ ├── Issue131Test.java
│ │ ├── Issue146Test.java
│ │ ├── Issue165Test.java
│ │ ├── Issue177Test.java
│ │ ├── Issue190Test.java
│ │ ├── Issue192Test.java
│ │ ├── Issue206Test.java
│ │ ├── Issue215Test.java
│ │ ├── Issue218Test.java
│ │ ├── Issue224Test.java
│ │ ├── Issue231Test.java
│ │ ├── Issue240Test.java
│ │ ├── Issue242Test.java
│ │ ├── Issue260Test.java
│ │ ├── Issue267Test.java
│ │ ├── Issue284Test.java
│ │ ├── Issue298Test.java
│ │ ├── Issue311Test.java
│ │ ├── Issue36Test.java
│ │ ├── Issue52Test.java
│ │ ├── Issue55Test.java
│ │ ├── Issue5Test.java
│ │ ├── Issue75Test.java
│ │ ├── Issue76Test.java
│ │ ├── Issue84Test.java
│ │ └── Issue9Test.java
│ ├── ListenersTest.java
│ ├── RateLimiterBuilderTest.java
│ ├── RetryPolicyBuilderTest.java
│ ├── testing
│ │ ├── Asserts.java
│ │ ├── Logging.java
│ │ ├── Mocking.java
│ │ ├── package-info.java
│ │ ├── TestCaseLogger.java
│ │ └── Testing.java
│ └── TimeoutBuilderTest.java
├── examples
│ ├── pom.xml
│ └── src
│ └── main
│ └── java
│ └── dev
│ └── failsafe
│ └── examples
│ ├── AsyncExample.java
│ ├── Java8Example.java
│ ├── NettyExample.java
│ ├── RetryLoopExample.java
│ ├── RxJavaExample.java
│ └── VertxExample.java
├── LICENSE
├── modules
│ ├── okhttp
│ │ ├── pom.xml
│ │ └── src
│ │ ├── main
│ │ │ └── java
│ │ │ └── dev
│ │ │ └── failsafe
│ │ │ └── okhttp
│ │ │ └── FailsafeCall.java
│ │ └── test
│ │ └── java
│ │ └── dev
│ │ └── failsafe
│ │ └── okhttp
│ │ ├── FailsafeCallTest.java
│ │ └── testing
│ │ └── OkHttpTesting.java
│ └── retrofit
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── dev
│ │ └── failsafe
│ │ └── retrofit
│ │ └── FailsafeCall.java
│ └── test
│ └── java
│ └── dev
│ └── retrofit
│ ├── FailsafeCallTest.java
│ ├── testing
│ │ └── RetrofitTesting.java
│ └── TestService.java
├── pom.xml
├── README.md
└── VERSIONING.md
56 directories, 218 files
好例子网口号:伸出你的我的手 — 分享!
小贴士
感谢您为本站写下的评论,您的评论对其它用户来说具有重要的参考价值,所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字,对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙,所以请不要反馈意义不大的重复字符,也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明,或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦,又没人会搭理,于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享,对搜索内容的合法性不具有预见性、识别性、控制性,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论平台是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定,若资源存在侵权或相关问题请联系本站客服人员,点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论