com.netflix.hystrix.Hystrix.reset()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(4.1k)|赞(0)|评价(0)|浏览(255)

本文整理了Java中com.netflix.hystrix.Hystrix.reset()方法的一些代码示例,展示了Hystrix.reset()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Hystrix.reset()方法的具体详情如下:
包路径:com.netflix.hystrix.Hystrix
类名称:Hystrix
方法名:reset

Hystrix.reset介绍

[英]Reset state and release resources in use (such as thread-pools).

NOTE: This can result in race conditions if HystrixCommands are concurrently being executed.
[中]重置状态并释放正在使用的资源(如线程池)。
注意:如果同时执行HYSTRIxCommand,这可能会导致争用条件。

代码示例

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected void before() {
  3. this.context = HystrixRequestContext.initializeContext();
  4. Hystrix.reset();
  5. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Before
  2. public void setup() {
  3. Hystrix.reset();
  4. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Before
  2. public void reset() {
  3. Hystrix.reset();
  4. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Before
  2. public void init() {
  3. HystrixCommandMetrics.reset();
  4. Hystrix.reset();
  5. }

代码示例来源:origin: PipelineAI/pipeline

  1. Hystrix.reset();

代码示例来源:origin: PipelineAI/pipeline

  1. @Before
  2. public void init() {
  3. for (HystrixCommandMetrics metricsInstance: HystrixCommandMetrics.getInstances()) {
  4. metricsInstance.resetStream();
  5. }
  6. HystrixCommandMetrics.reset();
  7. HystrixCircuitBreaker.Factory.reset();
  8. Hystrix.reset();
  9. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Ignore
  2. @Test
  3. public void testSuccessClosesCircuitWhenBusy() throws InterruptedException {
  4. HystrixPlugins.getInstance().registerCommandExecutionHook(new MyHystrixCommandExecutionHook());
  5. try {
  6. performLoad(200, 0, 40);
  7. performLoad(250, 100, 40);
  8. performLoad(600, 0, 40);
  9. } finally {
  10. Hystrix.reset();
  11. }
  12. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Test
  2. public void testResetCommandProperties() {
  3. HystrixCommand<Boolean> cmd1 = new ResettableCommand(100, 1, 10);
  4. assertEquals(100L, (long) cmd1.getProperties().executionTimeoutInMilliseconds().get());
  5. assertEquals(1L, (long) cmd1.getProperties().executionIsolationSemaphoreMaxConcurrentRequests().get());
  6. //assertEquals(10L, (long) cmd1.threadPool.getExecutor()..getCorePoolSize());
  7. Hystrix.reset();
  8. HystrixCommand<Boolean> cmd2 = new ResettableCommand(700, 2, 40);
  9. assertEquals(700L, (long) cmd2.getProperties().executionTimeoutInMilliseconds().get());
  10. assertEquals(2L, (long) cmd2.getProperties().executionIsolationSemaphoreMaxConcurrentRequests().get());
  11. //assertEquals(40L, (long) cmd2.threadPool.getExecutor().getCorePoolSize());
  12. }

代码示例来源:origin: org.springframework.cloud/spring-cloud-netflix-hystrix

  1. @Override
  2. public void destroy() throws Exception {
  3. // Just call Hystrix to reset thread pool etc.
  4. Hystrix.reset();
  5. }

代码示例来源:origin: io.smallrye/smallrye-fault-tolerance

  1. @PreDestroy
  2. void onShutdown() {
  3. LOGGER.info("### Reset Hystrix ###");
  4. Hystrix.reset(1, TimeUnit.SECONDS);
  5. }
  6. }

代码示例来源:origin: com.sap.cloud.s4hana.frameworks/hystrix

  1. /**
  2. * Safely shuts down Hystrix if not yet shut down. Invocation is synchronized on this class.
  3. */
  4. public void shutdown()
  5. {
  6. synchronized( HystrixBootstrapListener.class ) {
  7. if( isInitialized ) {
  8. if( logger.isInfoEnabled() ) {
  9. logger.info("Shutting down Hystrix.");
  10. }
  11. Hystrix.reset();
  12. isInitialized = false;
  13. } else {
  14. if( logger.isInfoEnabled() ) {
  15. logger.info("Hystrix already shut down.");
  16. }
  17. }
  18. }
  19. }

代码示例来源:origin: AvanzaBank/astrix

  1. private static void initHystrixPlugins() {
  2. try {
  3. registerDispatcherStrategies();
  4. } catch (Exception e) {
  5. log.warn("Failed to init Hystrix with custom Astrix strategies. Hystrix configuration will be reset and one more registreation attempt will be performed", e);
  6. Hystrix.reset();
  7. registerDispatcherStrategies();
  8. }
  9. }

代码示例来源:origin: com.yammer.tenacity/tenacity-core

  1. @Override
  2. public void stop() throws Exception {
  3. Hystrix.reset(shutdownGracePeriod.getQuantity(), shutdownGracePeriod.getUnit());
  4. }
  5. }

代码示例来源:origin: yammer/tenacity

  1. public void teardown() {
  2. Hystrix.reset(1, TimeUnit.SECONDS);
  3. ConfigurationManager.getConfigInstance().clear();
  4. }

代码示例来源:origin: yammer/tenacity

  1. @Override
  2. public void stop() throws Exception {
  3. Hystrix.reset(shutdownGracePeriod.getQuantity(), shutdownGracePeriod.getUnit());
  4. }
  5. }

代码示例来源:origin: yammer/tenacity

  1. private void setup() {
  2. resetStreams();
  3. Hystrix.reset();
  4. final AbstractConfiguration configuration = ConfigurationManager.getConfigInstance();
  5. configuration.setProperty("hystrix.command.default.metrics.healthSnapshot.intervalInMilliseconds", "100");
  6. }

代码示例来源:origin: com.redhat.lightblue/lightblue-core-hystrix

  1. Hystrix.reset();
  2. HystrixPlugins.reset();

相关文章