Оптимизация образца буферизации для параллельного выполнения с использованием BlockingCollection и Parallel.Invoke
На основеОптимизация буферизованного образца для параллельного выполнения этот вопрос возник.
Короче говоря:
Этот код выбрасывает много не может получить доступ к элементам исключений другого потока. Он создает пустые имена файлов и пропускает каждые 3 или около того чисел.
Цель состоит в том, чтобы не перепутать нумерацию (Nummerierung) при параллельном преобразовании массива байтов в изображение. Пожалуйста, обратитесь к ссылке для описания.
Что мне нужно изменить?
Action action = () =>
{
ArrayAnsammlung.TryTake(out data);
if (data != null)
{
Nummerierung = Convert.ToString(Interlocked.Increment(ref Nummerierungszaehler));
Enkodierung = null;
Enkodierung = new JpegBitmapEncoder();
Enkodierung.FlipHorizontal = true;
var dateiStrom = new FileStream("E:\\Temp\\" + datum + " " + Nummerierung.PadLeft(12, '0') + ".jpg", FileMode.Create);
Enkodierung.Frames.Add(BitmapFrame.Create(BitmapSource.Create(bildbreite, bildhoehe * 2,
96, 96, PixelFormats.Bgr32, null, data, stride)));
Enkodierung.Save(dateiStrom);
dateiStrom = null;
Enkodierung = null;
}
};
while (aufnahme)
{
try
{
Parallel.Invoke(action, action, action, action, action);
}
catch (AggregateException oo)
{
Console.WriteLine(oo.ToString());
}
Thread.Sleep(2000);
}