Thread.abort, похоже, не бросает Threadabortexception из-за Acceptsocket
-
01-10-2019 - |
Вопрос
я звоню ChannelServer.ListeningThread.Abort
На следующем потоке ничто не произойдет. Я хотел бы быть более конкретным, но я ничего не могу придумать. Кажется, нет ThreadAbortException
Это брошено, и это исключение должно быть брошено независимо от блокирующего слушателя (он отлично работает на потоках, которые являются блокирующе-приемлемыми).
Важное редактирование: С А. ManualResetEvent.WaitOne
вместо AcceptSocket
, Когда Лирик предложил для тестирования, он отлично работает. Почему AcceptSocket
блокирует ThreadAbortException
?
СВЯЗЬ: Эта нить форума, похоже, обсуждает ту же проблему, хотя я не могу понять что-нибудь из этого: http://www.tek-tips.com/viewthread.cfm?qid=319436&page=413.
ChannelServer.ListeningThread = new Thread(new ThreadStart(delegate()
{
Log.Inform("Waiting for clients on thread {0}.", Thread.CurrentThread.ManagedThreadId);
while (true)
{
try
{
new Thread(new ParameterizedThreadStart(ChannelClientHandler.Initialize)).Start(ChannelServer.Listener.AcceptSocket());
}
catch (ThreadAbortException)
{
Log.Inform("Aborted client listening thread {0}.", Thread.CurrentThread.ManagedThreadId);
break;
}
}
}));
ChannelServer.ListeningThread.Start();
Решение 2
Это работает, но это невероятно неряшно и тратация нити. Может ли кто-нибудь просто указать мне путь, чтобы выбрать исключение, что «ActionSocket» не будет автоматически поймать?
ChannelServer.ListeningThread = new Thread(new ThreadStart(delegate()
{
Log.Inform("Waiting for clients on thread {0}.", Thread.CurrentThread.ManagedThreadId);
while (true)
{
try
{
ChannelServer.ClientConnected.Reset();
ChannelServer.Listener.BeginAcceptSocket(new AsyncCallback(ChannelClientHandler.EndAcceptSocket), ChannelServer.Listener);
ChannelServer.ClientConnected.WaitOne();
}
catch (ThreadInterruptedException)
{
Log.Inform("Interrupted client listening thread {0}.", Thread.CurrentThread.ManagedThreadId);
break;
}
}
}));
ChannelServer.ListeningThread.Start();
Другие советы
Я не уверен, что вы получаете эту ошибку, но вот простой пример, который работает:
ManualResetEvent mrse = new ManualResetEvent(false);
Thread test = new Thread(() =>
{
while (true)
{
try
{
mrse.WaitOne();
}
catch (ThreadAbortException)
{
Console.WriteLine("No problem here...");
}
}
});
test.IsBackground = true;
test.Start();
Thread.Sleep(1000);
test.Abort();
Console.ReadKey();
Итак, это работает для меня ... Я предполагал, что вы вошли через отладчик, и ваша точка перерыва внутри выявления улов не ударилось, это правильно?
Примечание: это плохая практика, чтобы позвонить Abort
, вместо этого вы должны позвонить Interrupt
и обрабатывать ThreadInterruptedException
... Это намного безопаснее.
Вот простой AcceptSocket2
Метод расширения (извините за отсутствие воображения относительно имени ...). Это работает точно так же, как оригинал AcceptSocket
метод.
using System;
using System.Net.Sockets;
using System.Threading;
/// <summary>
/// Extensions to TcpListener
/// </summary>
public static class TcpListenerExtensions
{
/// <summary>
/// Accepts a pending connection request.
/// </summary>
/// <param name="tcpListener">The TCP listener.</param>
/// <returns>
/// A <see cref="T:System.Net.Sockets.Socket" /> used to send and receive data.
/// </returns>
/// <exception cref="T:System.InvalidOperationException">The listener has not been started with a call to <see cref="M:System.Net.Sockets.TcpListener.Start" />.</exception>
/// <PermissionSet><IPermission class="System.Security.Permissions.EnvironmentPermission, mscorlib, Version=2.0.3600.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" version="1" Unrestricted="true" /><IPermission class="System.Security.Permissions.FileIOPermission, mscorlib, Version=2.0.3600.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" version="1" Unrestricted="true" /><IPermission class="System.Security.Permissions.SecurityPermission, mscorlib, Version=2.0.3600.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" version="1" Flags="UnmanagedCode, ControlEvidence" /><IPermission class="System.Diagnostics.PerformanceCounterPermission, System, Version=2.0.3600.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" version="1" Unrestricted="true" /></PermissionSet>
public static Socket AcceptSocket2(this TcpListener tcpListener)
{
Socket socket = null;
var clientConnected = new ManualResetEvent(false);
clientConnected.Reset();
tcpListener.BeginAcceptSocket(delegate(IAsyncResult asyncResult)
{
try
{
socket = tcpListener.EndAcceptSocket(asyncResult);
}
catch (ObjectDisposedException)
{ }
clientConnected.Set();
}, null);
clientConnected.WaitOne();
return socket;
}
}