线程池会排队一个定时器的回调函数,有时会同时调度多个线程吗?
-
11-12-2019 - |
题
在下面的代码中 TimerRecalcStatisticsElapsed
应该只运行它的一个实例。此回调调用的工作方法按顺序运行, 一次最多运行一个线程.
问题第 1 部分:
如果计时器的回调运行一个线程池线程(而不是在单独的线程上运行回调),线程池可能会根据条件(达到最大线程数,线程池内部逻辑)排队并推迟线程以供以后执行,这种说法是否正确?
问题第二部分:
假设一个计时器回调可以排队等待除立即执行之外的任何操作,这是否意味着可以同时执行任意数量的线程回调?
问题第 3 部分
假设第 2 部分为真,这是否意味着下面的代码可以同时运行多个回调?
我问的原因是因为有 数千个实例 此类在多 CPU 服务器上运行。我还看到数据损坏与无序操作一致 // Do Work Here
.
在旁边
// Do work here
在内部使用 System.Collections.Dictionary 并编辑 y 的值。它还删除了串行调用的后续函数的一些键。该函数缺少先前在第一次调用中出现的键 (x)。我认为这是因为最终声明存在竞争条件 obj.cleanupdata()
public class SystemTimerTest
{
readonly System.Timers.Timer timerRecalcStatistics;
readonly System.Diagnostics.Stopwatch stopwatchForRecalcStatistics = new System.Diagnostics.Stopwatch();
public SystemTimerTest(TimeSpan range, DataOverwriteAction action)
{
int recalculateStatisticsEveryXMillseconds = 1000;
timerRecalcStatistics = new System.Timers.Timer(recalculateStatisticsEveryXMillseconds);
timerRecalcStatistics.AutoReset = true;
timerRecalcStatistics.Elapsed += new System.Timers.ElapsedEventHandler(TimerRecalcStatisticsElapsed);
timerRecalcStatistics.Interval = recalculateStatisticsEveryXMillseconds;
timerRecalcStatistics.Enabled = true;
this.maxRange = range;
this.hashRunningTotalDB = new HashRunningTotalDB(action);
this.hashesByDate = new HashesByDate(action);
this.dataOverwriteAction = action;
}
private void TimerRecalcStatisticsElapsed(object source, System.Timers.ElapsedEventArgs e)
{
stopwatchForRecalcStatistics.Start();
Console.WriteLine("The TimerRecalcStatisticsElapsed event was raised at {0}", e.SignalTime.ToString("o"));
// DO WORK HERE
stopwatchForRecalcStatistics.Stop();
double timeBuffer = GetInterval(IntervalTypeEnum.NearestSecond, e.SignalTime) - stopwatchForRecalcStatistics.ElapsedMilliseconds;
if (timeBuffer > 0)
timerRecalcStatistics.Interval = timeBuffer;
else
timerRecalcStatistics.Interval = 1;
stopwatchForRecalcStatistics.Reset();
timerRecalcStatistics.Enabled = true;
}
}
解决方案
ad 1) ThreadPool 是否可以推迟回调方法的执行并不重要,因为无论如何,回调都不能保证在另一个计时器间隔过去之前完成执行(例如,线程可以被线程调度程序挂起,或者回调可能会调用 long-运行功能)。
ad 2)这就是MSDN所说的 定时器 班级:
如果SynChronizingObject属性为null,则在线程泵线上升起了经过的事件。如果处理过的事件的持续时间比间隔更长,则可能会在另一个线程池线程上再次提高该事件。在这种情况下,活动处理程序应重新进入。
所以答案是肯定的,回调可以在多个线程上同时执行。
广告 3)是的。并且您应该避免在回调方法中使用共享资源(timerRecalcStatistics、stopwatchForRecalcStatistics),或者同步对这些共享资源的访问(例如使用锁),或者为 Timer 设置适当的对象 同步对象 属性,或将 Timer 的 AutoReset 属性设置为 false(并在计时器回调结束时再次启用计时器)。
更新:我认为乔恩·斯基特 回答 并不能解决你的问题。恕我直言,实现您自己的 SynchonizingObject 比必要的更复杂(但在不了解整个问题的情况下很难说)。我希望这个实现应该有效(但我没有测试它):
public class MySynchronizeInvoke : ISynchronizeInvoke
{
private object SyncObject = new Object();
private delegate object InvokeDelegate(Delegate method, object[] args);
public IAsyncResult BeginInvoke(Delegate method, object[] args)
{
ElapsedEventHandler handler = (ElapsedEventHandler)method;
InvokeDelegate D = Invoke;
return D.BeginInvoke(handler, args, CallbackMethod, null);
}
private void CallbackMethod(IAsyncResult ar)
{
AsyncResult result = ar as AsyncResult;
if(result != null)
((InvokeDelegate)result.AsyncDelegate).EndInvoke(ar);
}
public object EndInvoke(IAsyncResult result)
{
result.AsyncWaitHandle.WaitOne();
return null;
}
public object Invoke(Delegate method, object[] args)
{
lock(SyncObject)
{
ElapsedEventHandler handler = (ElapsedEventHandler)method;
handler(args[0], (ElapsedEventArgs)args[1]);
return null;
}
}
public bool InvokeRequired
{
get { return true; }
}
}
其他提示
如果SynChronizingObject属性为null,则在线程泵线上升起了经过的事件。如果处理过的事件的持续时间比间隔更长,则可能会在另一个线程池线程上再次提高该事件。在这种情况下,活动处理程序应重新进入。
所以回答你的问题:
是的,它在线程池线程上运行,并且像其他任何事情一样受到线程池填充和延迟的影响。鉴于线程池现在最多有数百个线程,这应该不是问题。如果是的话,你就有更大的问题了。
假设您没有设置同步对象或以其他方式同步您的回调,是的,多个回调可以重叠。如果给计时器一个同步对象,它就不会“重叠”事件。
您提供的代码不会以任何方式同步它的回调,因此它可以有多个重叠的、同时执行的回调副本。如果您希望类的所有实例彼此同步,则应该使用类似 lock 语句的方法来同步该方法;如果您希望类的每个单独实例只运行一个回调,则应使用计时器的 SynchronizingObject在任何给定时间。