Circuit breaker (шаблон проєктування) — Вікіпедія

using System; using System.Threading;  namespace CircuitBreakerPattern { 	public interface IService 	{ 		// виконання операції 		string GetValue();  		// виконання операції базуючись на результаті від іншого сервісу 		string GetModifiedValue(IService service) 		{ 			try 			{ 				return $"From another service: {service.GetValue()}"; 			} 			catch 			{ 				return "Call another service failed"; 			} 		} 	}  	public class ServiceA : IService 	{ 		public string GetValue() 		{ 			return "Service A"; 		} 	} 	public class ServiceB : IService 	{ 		public string GetValue() 		{ 			// 50% шанс аварійного завершення 			if (new Random().NextDouble() > 0.5) 			{ 				// імітуємо довготривалу роботу 				Thread.Sleep(5000);  				throw new InvalidOperationException(); 			}  			return "Service B"; 		} 	}  	public enum CircuitBreakerStateEnum 	{ 		Closed = 0, 		Open = 1, 		HalfOpen = 2, 	} 	interface ICircuitBreaker 	{ 		CircuitBreakerStateEnum State { get; }  		int FailThreshold { get; set; } // максимальна кількість невдалих запитів потрібних для переходу в Open стан  		// оригінальний алгоритм передбачає використання таймеру 		int RetriesThreshold { get; set; } // максимальна кількість запитів потрібних для переходу в HalfOpen стан 	}  	public class ServiceBProxy : IService, ICircuitBreaker 	{ 		private readonly IService _service;  		public ServiceBProxy(IService service) 		{ 			_service = service; 		}  		private int _currentFailAttempt; 		private int _retriesAttempt;  		public CircuitBreakerStateEnum State { get; private set; } = CircuitBreakerStateEnum.Closed; 		public int FailThreshold { get; set; } = 2; 		public int RetriesThreshold { get; set; } = 3;   		public string GetValue() 		{ 			if (State == CircuitBreakerStateEnum.Closed) 			{ 				return GetValueInClosedState(); 			} 			else if (State == CircuitBreakerStateEnum.Open) 			{ 				return GetValueInOpenState(); 			} 			else // if (State == CircuitBreakerStateEnum.HalfOpen) 			{ 				return GetValueInHalfOpenState(); 			} 		}  		private string GetValueInClosedState() 		{ 			try 			{ 				// делегуємо запит допоміжному сервісу 				return _service.GetValue(); 			} 			catch 			{ 				// підраховуємо невдалі запити 				++_currentFailAttempt;  				// при перевищені ліміту переходимо в Open стан 				if (_currentFailAttempt >= FailThreshold) Open();  				throw; 			} 		} 		private string GetValueInOpenState() 		{ 			// рахуємо запити  			++_retriesAttempt;  			// при перевищені ліміту переходимо в HalfOpen стан 			if (_retriesAttempt > RetriesThreshold) HalfOpen();  			// без затримки повідомляємо про помилку в системі 			throw new InvalidOperationException(); 		}  		private string GetValueInHalfOpenState() 		{ 			try 			{ 				// робимо запит 				var value = _service.GetValue();  				// у разі успішного виконання переходимо в стан Closed 				Close();  				return value; 			} 			catch 			{ 				// при помилці переходимо в стан Open 				Open(); 				throw; 			} 		}   		private void Open() 		{ 			ResetCounter(); 			State = CircuitBreakerStateEnum.Open; 		}  		private void HalfOpen() 		{ 			ResetCounter(); 			State = CircuitBreakerStateEnum.HalfOpen; 		}  		private void Close() 		{ 			ResetCounter(); 			State = CircuitBreakerStateEnum.Closed; 		}  		private void ResetCounter() 		{ 			_currentFailAttempt = 0; 			_retriesAttempt = 0; 		} 	}  	class Program 	{ 		static void Main(string[] args) 		{ 			IService serviceA = new ServiceA(); 			IService serviceB = new ServiceB();  			// обгортаємо допоміжний сервіс, proxy-сервісом, який реалізовує логіку Circuit Breaker 			serviceB = new ServiceBProxy(serviceB);  			// несправності в допоміжному сервісі блокують основний 			for (int i = 0; i < 20; ++i) 			{ 				Console.WriteLine($"Request {i}");  				Console.WriteLine(serviceA.GetValue()); 				Console.WriteLine(serviceA.GetModifiedValue(serviceB)); 				Console.WriteLine(); 			} 		} 	} }