iframe-proxy | Sunbelt Computer Software

History

106 lines (88 loc) · 2.84 KB

Raw

100

101

102

103

104

105

106

using System;

using System.Threading;

namespace MuPDF.NET

{

#if ENABLE_PARALLEL

internal static class ParallelRunner

{

static int coreCount;

static ParallelRunner()

{

coreCount = 8;

}

public static void For(int fromInclusive, int toExclusive, Action<int> act)

{

For(fromInclusive, toExclusive, -1, 1, (pair) =>

{

var from = pair.From;

var to = pair.To;

for (int i = from; i < to; i++)

act(i);

});

}

public static void For(int fromInclusive, int toExclusive, int maxThreadsCount, int minPartitionSize, Action<Pair> act)

{

var threadCount = maxThreadsCount < 1 ? coreCount : maxThreadsCount;

var partSize = Math.Max(minPartitionSize, 1 + (toExclusive - fromInclusive) / threadCount);

var waits = new AutoResetEvent[threadCount];

for (int iThread = 0; iThread < threadCount; iThread++)

{

var iT = iThread;

var from = fromInclusive + iThread * partSize;

var to = Math.Min(toExclusive, fromInclusive + (iThread + 1) * partSize);

waits[iT] = new AutoResetEvent(false);

if (from >= to)

{

waits[iT].Set();

continue;

}

new Thread(

(o) =>

{

var pair = new Pair { From = from, To = to };

//Console.WriteLine(pair);

act(pair);

waits[iT].Set();

}

)

{ IsBackground = true }.Start();

}

//wait all threads

for (int iThread = 0; iThread < threadCount; iThread++)

waits[iThread].WaitOne();

}

public struct Pair

{

public int From;

public int To;

public override string ToString()

{

return From + " - " + To;

}

#endif

#if !ENABLE_PARALLEL

internal static class ParallelRunner

{

public static void For(int fromInclusive, int toExclusive, Action<int> act)

{

for (int i = fromInclusive; i < toExclusive; i++)

act(i);

}

public static void For(int fromInclusive, int toExclusive, int maxThreadsCount, int minPartitionSize, Action<Pair> act)

{

act(new Pair { From = fromInclusive, To = toExclusive });

}

public struct Pair

{

public int From;

public int To;

public override string ToString()

{

return From + " - " + To;

}

#endif

}

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Sunbelt Computer Software

PL/B Language Development and Support

FilesExpand file tree

Parallel.cs

Latest commit

History

Parallel.cs

File metadata and controls