weiai/TouchSocket
1
0
Fork 0
mirror of https://github.com/RRQM/TouchSocket.git synced 2025-12-18 09:26:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix ReconnectionPlugin Dispose Error! (#68)

Browse Source
This commit is contained in:
godchadigo
2025-07-08 19:55:17 +08:00
committed by GitHub
parent 97bcb03dac
commit d3d0a99c3e
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/TouchSocket/Plugins/ReconnectionPlugin.cs
View File

@@ -11,6 +11,7 @@
//------------------------------------------------------------------------------
using System;
using System.Threading;
using System.Threading.Tasks;
using TouchSocket.Core;
using TouchSocket.Resources;
@@ -23,6 +24,7 @@ namespace TouchSocket.Sockets;
public abstract class ReconnectionPlugin<TClient> : PluginBase, ILoadedConfigPlugin where TClient : IDisposableObject, IConnectableClient, IOnlineClient, ILoggerObject
{
private Task m_beginReconnectTask;
private CancellationTokenSource _cancellationBeginReconnectTaskTokenSource;
private bool m_polling;
private TimeSpan m_tick = TimeSpan.FromSeconds(1);
@@ -43,6 +45,7 @@ public abstract class ReconnectionPlugin<TClient> : PluginBase, ILoadedConfigPlu
return false;
}
};
this._cancellationBeginReconnectTaskTokenSource = new CancellationTokenSource();
}
/// <summary>
@@ -63,7 +66,7 @@ public abstract class ReconnectionPlugin<TClient> : PluginBase, ILoadedConfigPlu
/// <inheritdoc/>
public async Task OnLoadedConfig(IConfigObject sender, ConfigEventArgs e)
{
this.m_beginReconnectTask = EasyTask.Run(this.BeginReconnect, sender);
this.m_beginReconnectTask = EasyTask.Run(this.BeginReconnect, sender, _cancellationBeginReconnectTaskTokenSource.Token);
await e.InvokeNext().ConfigureAwait(EasyTask.ContinueOnCapturedContext);
}
@@ -230,7 +233,7 @@ public abstract class ReconnectionPlugin<TClient> : PluginBase, ILoadedConfigPlu
{
if (disposing)
{
this.m_beginReconnectTask.Dispose();
this._cancellationBeginReconnectTaskTokenSource.Cancel();
}
base.Dispose(disposing);
}
@@ -253,7 +256,7 @@ public abstract class ReconnectionPlugin<TClient> : PluginBase, ILoadedConfigPlu
try
{
while (true)
while (!_cancellationBeginReconnectTaskTokenSource.IsCancellationRequested)
{
if (this.DisposedValue)
{