dispose CancellationTokenSource and publish v2.1.1

li-zheng-hao · Nov 29, 2024 · 07b6103 · 07b6103
1 parent e205e80
commit 07b6103
Show file tree

Hide file tree

Showing 6 changed files with 14 additions and 11 deletions.
diff --git a/src/LightMQ.OpenTelemetry/LightMQ.OpenTelemetry.csproj b/src/LightMQ.OpenTelemetry/LightMQ.OpenTelemetry.csproj
@@ -7,7 +7,7 @@
         <GenerateDocumentationFile>true</GenerateDocumentationFile>
         <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
         <IncludeSymbols>true</IncludeSymbols>
-        <Version>2.1.0-preview2</Version>
+        <Version>2.1.1</Version>
         <Title>LightMQ.OpenTelemetry</Title>
         <Authors>lizhenghao</Authors>
         <PackageProjectUrl>https://github.com/li-zheng-hao/LightMQ</PackageProjectUrl>

diff --git a/src/LightMQ.Storage.MongoDB/LightMQ.Storage.MongoDB.csproj b/src/LightMQ.Storage.MongoDB/LightMQ.Storage.MongoDB.csproj
@@ -7,7 +7,7 @@
         <GenerateDocumentationFile>true</GenerateDocumentationFile>
         <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
         <IncludeSymbols>true</IncludeSymbols>
-        <Version>2.1.0-preview2</Version>
+        <Version>2.1.1</Version>
         <Title>LightMQ.Storage.MongoDB</Title>
         <Authors>lizhenghao</Authors>
         <PackageProjectUrl>https://github.com/li-zheng-hao/LightMQ</PackageProjectUrl>

diff --git a/src/LightMQ.Storage.SqlServer/LightMQ.Storage.SqlServer.csproj b/src/LightMQ.Storage.SqlServer/LightMQ.Storage.SqlServer.csproj
@@ -7,7 +7,7 @@
         <GenerateDocumentationFile>true</GenerateDocumentationFile>
         <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
         <IncludeSymbols>true</IncludeSymbols>
-        <Version>2.1.0-preview2</Version>
+        <Version>2.1.1</Version>
         <Title>LightMQ.Storage.SqlServer</Title>
         <Authors>lizhenghao</Authors>
         <PackageProjectUrl>https://github.com/li-zheng-hao/LightMQ</PackageProjectUrl>

diff --git a/src/LightMQ.Storage.Sqlite/LightMQ.Storage.Sqlite.csproj b/src/LightMQ.Storage.Sqlite/LightMQ.Storage.Sqlite.csproj
@@ -7,7 +7,7 @@
         <GenerateDocumentationFile>true</GenerateDocumentationFile>
         <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
         <IncludeSymbols>true</IncludeSymbols>
-        <Version>2.1.0-preview2</Version>
+        <Version>2.1.1</Version>
         <Title>LightMQ.Storage.Sqlite</Title>
         <Authors>lizhenghao</Authors>
         <PackageProjectUrl>https://github.com/li-zheng-hao/LightMQ</PackageProjectUrl>

diff --git a/src/LightMQ/DispatcherService.cs b/src/LightMQ/DispatcherService.cs
@@ -9,7 +9,7 @@
 
 namespace LightMQ;
 
-public class DispatcherService :IHostedService
+public class DispatcherService : IHostedService
 {
     private readonly ILogger<DispatcherService> _logger;
     private readonly IServiceProvider _serviceProvider;
@@ -40,11 +40,11 @@ IEnumerable<IBackgroundService> backgroundServices
     }
 
     /// <summary>
-    /// 
+    ///
     /// </summary>
     /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    public  Task StartAsync(CancellationToken cancellationToken)
+    public Task StartAsync(CancellationToken cancellationToken)
     {
         return Run(cancellationToken);
     }
@@ -112,7 +112,7 @@ public async Task StopAsync(CancellationToken cancellationToken)
 
         try
         {
-            var tokenSource = new CancellationTokenSource();
+            using var tokenSource = new CancellationTokenSource();
             tokenSource.CancelAfter(_options.Value.ExitTimeOut);
             while (true)
             {
@@ -134,8 +134,11 @@ public async Task StopAsync(CancellationToken cancellationToken)
         {
             _logger.LogInformation("LightMQ等待退出超时，强制退出");
         }
+        finally
+        {
+            _cancel.Dispose();
+        }
 
         _logger.LogInformation("LightMQ服务停止");
     }
-
-}
+}
diff --git a/src/LightMQ/LightMQ.csproj b/src/LightMQ/LightMQ.csproj
@@ -7,7 +7,7 @@
         <GenerateDocumentationFile>true</GenerateDocumentationFile>
         <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
         <IncludeSymbols>true</IncludeSymbols>
-        <Version>2.1.0-preview2</Version>
+        <Version>2.1.1</Version>
         <Title>LightMQ</Title>
         <Authors>lizhenghao</Authors>
         <PackageProjectUrl>https://github.com/li-zheng-hao/LightMQ</PackageProjectUrl>