{"id":8292,"date":"2024-02-19T12:20:58","date_gmt":"2024-02-19T11:20:58","guid":{"rendered":"https:\/\/solidt.eu\/site\/?p=8292"},"modified":"2024-06-24T16:01:51","modified_gmt":"2024-06-24T15:01:51","slug":"c-throttle-function","status":"publish","type":"post","link":"https:\/\/solidt.eu\/site\/c-throttle-function\/","title":{"rendered":"C# Throttle Function"},"content":{"rendered":"\n<div style=\"height: 250px; position:relative; margin-bottom: 50px;\" class=\"wp-block-simple-code-block-ace\"><pre class=\"wp-block-simple-code-block-ace\" style=\"position:absolute;top:0;right:0;bottom:0;left:0\" data-mode=\"csharp\" data-theme=\"monokai\" data-fontsize=\"14\" data-lines=\"Infinity\" data-showlines=\"true\" data-copy=\"false\">public class Throttle&lt;T>\r\n{\r\n    private readonly Func&lt;Task&lt;T>> _initialFn;\r\n    private readonly TimeSpan _throttleTime;\r\n    private TaskCompletionSource&lt;T> _tcs;\r\n    private DateTime _lastExecutionTime;\r\n    private readonly object _lock = new object();\r\n\r\n    public Throttle(TimeSpan throttleTime, Func&lt;Task&lt;T>> initialFn)\r\n    {\r\n        _initialFn = initialFn ?? throw new ArgumentNullException(nameof(initialFn));\r\n        _throttleTime = throttleTime;\r\n        _tcs = new TaskCompletionSource&lt;T>();\r\n        _lastExecutionTime = DateTime.MinValue;\r\n    }\r\n\r\n    private bool IsThrottleTimeElapsed()\r\n    {\r\n        return DateTime.UtcNow - _lastExecutionTime >= _throttleTime;\r\n    }\r\n\r\n    public void ClearLastExecutionTime()\r\n    {\r\n        lock (_lock)\r\n        {\r\n            _lastExecutionTime = DateTime.MinValue;\r\n        }\r\n    }\r\n    private async Task&lt;T> ExecuteInitialFunctionAsync()\r\n    {\r\n        try\r\n        {\r\n            var result = await _initialFn();\r\n            _tcs.TrySetResult(result);\r\n        }\r\n        catch (Exception ex)\r\n        {\r\n            _tcs.TrySetException(ex);\r\n        }\r\n\r\n        return await _tcs.Task;\r\n    }\r\n\r\n    public Task&lt;T> ExecuteAsync()\r\n    {\r\n        Task&lt;T> taskToAwait;\r\n\r\n        lock (_lock)\r\n        {\r\n            if (!IsThrottleTimeElapsed())\r\n            {\r\n                taskToAwait = _tcs.Task;\r\n            }\r\n            else\r\n            {\r\n                _tcs = new TaskCompletionSource&lt;T>();\r\n                _lastExecutionTime = DateTime.UtcNow;\r\n                taskToAwait = ExecuteInitialFunctionAsync();\r\n            }\r\n        }\r\n\r\n        return taskToAwait;\r\n    }\r\n}<\/pre><\/div>\n","protected":false},"excerpt":{"rendered":"","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"inline_featured_image":false,"footnotes":""},"categories":[1],"tags":[],"class_list":["post-8292","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"_links":{"self":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts\/8292","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/comments?post=8292"}],"version-history":[{"count":3,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts\/8292\/revisions"}],"predecessor-version":[{"id":8633,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts\/8292\/revisions\/8633"}],"wp:attachment":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/media?parent=8292"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/categories?post=8292"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/tags?post=8292"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}