Проблема, кажется, находится в Windows I/O, планируя политику. Согласно тому, что я нашел здесь , существует много путей к O.S. для планирования дисковых запросов. В то время как Linux и другие могут выбрать между различными политиками, прежде чем Windows Vista был заблокирован в единственной политике: очередь FIFO, где все запросы, где splitted в блоках на 64 КБ. Я полагаю, что эта политика является причиной для проблемы, которую Вы испытываете: планировщик смешает запросы от двух потоков, вызывать непрерывный ищет между различными областями диска.
Теперь, хорошие новости - то, что согласно здесь и здесь , Vista представил более умный дисковый планировщик, где можно установить приоритет запросов и также выделить минимум badwidth для процесса.
плохие новости - то, что я не нашел способа изменить дисковую политику или буферный размер в предыдущих версиях Windows. Кроме того, даже если повышение дискового приоритета ввода-вывода Вашего процесса повысит производительность против других процессов, у Вас все еще есть проблемы Ваших потоков, конкурирующих друг против друга.
то, Что я могу предложить, должно изменить Ваше программное обеспечение путем представления самодельной политики доступа к диску.
, Например, Вы могли использовать политику как это в Вашем потоке B (подобный для Потока A):
if THREAD A is reading from disk then wait for THREAD A to stop reading or wait for X ms
Read for X ms (or Y MB)
Stop reading and check status of thread A again
Вы могли использовать семафоры для проверки состояния, или Вы могли использовать счетчики perfmon для получения состояния очереди фактической дисковой емкости. Значения X и/или Y могли также быть автоматически настроены путем проверки фактических trasfer уровней и медленно изменить их, таким образом максимизировав пропускную способность когда выполнение приложения на различных машинах и/или O.S. Вы могли найти, что кэш, память или уровни RAID влияют на них способом или другой, но с автоматической настройкой Вас будет всегда получать лучшую производительность в каждом сценарии.
Я нашел решение.
Я создал класс EventHandler:
public class NVelocityEventHandler : IInvalidReferenceEventHandler, IMethodExceptionEventHandler
{
#region IInvalidReferenceEventHandler Members
public object InvalidGetMethod(NVelocity.Context.IContext context, string reference, object object_Renamed, string property, NVelocity.Util.Introspection.Info info)
{
return "InvalidGetMethod:" + reference;
}
public object InvalidMethod(NVelocity.Context.IContext context, string reference, object object_Renamed, string method, NVelocity.Util.Introspection.Info info)
{
return "InvalidMethod:" + reference;
}
public bool InvalidSetMethod(NVelocity.Context.IContext context, string leftreference, string rightreference, NVelocity.Util.Introspection.Info info)
{
return true;
}
#endregion
#region IMethodExceptionEventHandler Members
object IMethodExceptionEventHandler.MethodException(Type claz, string method, Exception e)
{
return "MethodException:" + method;
}
#endregion
}
Затем я использую его в приведенном ниже коде:
StringWriter writer = new StringWriter();
NVelocity.App.VelocityEngine eng = new NVelocity.App.VelocityEngine();
try
{
NVelocityEventHandler te = new NVelocityEventHandler();
EventCartridge ec = new EventCartridge();
ec.AddEventHandler(te);
VelocityContext vc = new VelocityContext((IDictionary)parameters);
ec.AttachToContext(vc);
eng.Evaluate(vc, writer, "templatestring", template);
}
catch (ParseErrorException pe)
{
return pe.Message;
}
catch (MethodInvocationException mi)
{
return mi.Message;
}