Add field to extractor to set the scheduler timeout (#543)

There's currently no way to pass this to the base extractor, so the timeout feature isn't very helpful...

Author: einarmo

ExtractorUtils/BaseExtractor.cs

@@ -77,6 +77,12 @@ public abstract class BaseExtractor<TConfig> : IDisposable, IAsyncDisposable
         /// </summary>
         protected RemoteConfigManager<TConfig>? ConfigManager { get; }
 
+        /// <summary>
+        /// Timeout in milliseconds for the scheduler to shut down when closing.
+        /// Defaults to 0, which waits forever.
+        /// </summary>
+        protected int SchedulerExitTimeoutMs { get; set; }
+
         private readonly ILogger<BaseExtractor<TConfig>> _logger;
 
         /// <summary>
@@ -383,7 +389,7 @@ protected virtual void Dispose(bool disposing)
                     try
                     {
                         // Cannot be allowed to fail here
-                        Scheduler.ExitAllAndWait().Wait();
+                        Scheduler.ExitAllAndWait(SchedulerExitTimeoutMs).Wait();
                     }
                     catch { }
                     Scheduler.Dispose();
@@ -417,7 +423,7 @@ protected virtual async ValueTask DisposeAsyncCore()
             {
                 try
                 {
-                    await Scheduler.ExitAllAndWait().ConfigureAwait(false);
+                    await Scheduler.ExitAllAndWait(SchedulerExitTimeoutMs).ConfigureAwait(false);
                 }
                 catch (Exception ex)
                 {

version

@@ -1 +1 @@
-1.33.0
+1.34.0