我正在通过端口和接收器连接15个异步操作。这让我非常关注线程间消息传递的时间，尤其是任务将数据发布到端口后，在不同线程上开始处理相同数据之间所需的时间。假设每个线程都在启动时处于空闲状态的最佳情况下，我生成了一个测试，使用计时器类来测量两个不同调度程序之间的时间，每个调度程序都以单个线程的最高优先级运行。
令我惊讶的是，我的开发机是一台运行Windows 7 x64的Q6600四核2.4 Ghz电脑，我的测试平均上下文切换时间为5.66微秒，标准差为5.738微秒，最大值接近1.58毫秒（282倍！）。计时器频率为427.7纳秒，因此我仍然远离传感器噪声。
我想要做的是尽可能地减少线程间消息传递时间，并同样重要的是减少上下文切换的标准差。我意识到Windows不是实时操作系统，没有任何保证，但Windows调度程序是一个公平的轮询优先级调度程序，并且此测试中的两个线程都处于最高优先级（唯一应该如此的线程），因此不应该有任何线程上的上下文切换（通过1.58 ms最长时间可见...我相信Windows quantum是15.65 ms？）我唯一能想到的是操作系统调用CCR使用的锁定机制的时间差异，以在线程之间传递消息。
请告诉我是否有其他人测量过线程间消息传递时间，并且对如何改进它有任何建议。
这是我的测试源代码：
令我惊讶的是，我的开发机是一台运行Windows 7 x64的Q6600四核2.4 Ghz电脑，我的测试平均上下文切换时间为5.66微秒，标准差为5.738微秒，最大值接近1.58毫秒（282倍！）。计时器频率为427.7纳秒，因此我仍然远离传感器噪声。
我想要做的是尽可能地减少线程间消息传递时间，并同样重要的是减少上下文切换的标准差。我意识到Windows不是实时操作系统，没有任何保证，但Windows调度程序是一个公平的轮询优先级调度程序，并且此测试中的两个线程都处于最高优先级（唯一应该如此的线程），因此不应该有任何线程上的上下文切换（通过1.58 ms最长时间可见...我相信Windows quantum是15.65 ms？）我唯一能想到的是操作系统调用CCR使用的锁定机制的时间差异，以在线程之间传递消息。
请告诉我是否有其他人测量过线程间消息传递时间，并且对如何改进它有任何建议。
这是我的测试源代码：
using System;
using System.Collections.Generic;
using System.IO;
using System.Threading;
using Microsoft.Ccr.Core;
using System.Diagnostics;
namespace Test.CCR.TestConsole
{
class Program
{
static void Main(string[] args)
{
Console.WriteLine("Starting Timer");
var sw = new Stopwatch();
sw.Start();
var dispatcher = new Dispatcher(1, ThreadPriority.Highest, true, "My Thread Pool");
var dispQueue = new DispatcherQueue("Disp Queue", dispatcher);
var sDispatcher = new Dispatcher(1, ThreadPriority.Highest, true, "Second Dispatcher");
var sDispQueue = new DispatcherQueue("Second Queue", sDispatcher);
var legAPort = new Port<EmptyValue>();
var legBPort = new Port<TimeSpan>();
var distances = new List<double>();
long totalTicks = 0;
while (sw.Elapsed.TotalMilliseconds < 5000) ;
int runCnt = 100000;
int offset = 1000;
Arbiter.Activate(dispQueue, Arbiter.Receive(true, legAPort, i =>
{
TimeSpan sTime = sw.Elapsed;
legBPort.Post(sTime);
}));
Arbiter.Activate(sDispQueue, Arbiter.Receive(true, legBPort, i =>
{
TimeSpan eTime = sw.Elapsed;
TimeSpan dt = eTime.Subtract(i);
//if (distances.Count == 0 || Math.Abs(distances[distances.Count - 1] - dt.TotalMilliseconds) / distances[distances.Count - 1] > 0.1)
distances.Add(dt.TotalMilliseconds);
if(distances.Count > offset)
Interlocked.Add(ref totalTicks,
dt.Ticks);
if(distances.Count < runCnt)
legAPort.Post(EmptyValue.SharedInstance);
}));
//Thread.Sleep(100);
legAPort.Post(EmptyValue.SharedInstance);
Thread.Sleep(500);
while (distances.Count < runCnt)
Thread.Sleep(25);
TimeSpan exTime = TimeSpan.FromTicks(totalTicks);
double exMS = exTime.TotalMilliseconds / (runCnt - offset);
Console.WriteLine("Exchange Time: {0} Stopwatch Resolution: {1}", exMS, Stopwatch.Frequency);
using(var stw = new StreamWriter("test.csv"))
{
for(int ix=0; ix < distances.Count; ix++)
{
stw.WriteLine("{0},{1}", ix, distances[ix]);
}
stw.Flush();
}
Console.ReadKey();
}
}
}