FilesExpand file tree

main

/

ForEachSynchronousLoop.cs

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

43 lines (38 loc) · 1.57 KB

main

/

ForEachSynchronousLoop.cs

Copy path

Top

File metadata and controls

• Code
• Blame

43 lines (38 loc) · 1.57 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

using System;

using System.Collections.Generic;

using System.Threading.Tasks;

using Cuemon.Collections.Generic;

namespace Cuemon.Threading;

internal abstract class ForEachSynchronousLoop<TSource> : SynchronousLoop<TSource>

{

protected ForEachSynchronousLoop(IEnumerable<TSource> source, Action<AsyncTaskFactoryOptions> setup) : base(setup)

{

Partitioner = new PartitionerEnumerable<TSource>(source, Options.PartitionSize);

WhileCondition = () => Partitioner.HasPartitions;

Sorter = 0;

}

private PartitionerEnumerable<TSource> Partitioner { get; set; }

private long Sorter { get; set; }

protected sealed override void FillWorkQueue<TWorker>(MutableTupleFactory<TWorker> worker, IList<Func<Task>> queue)

{

foreach (var item in Partitioner)

{

var shallowWorkerFactory = worker.Clone();

shallowWorkerFactory.GenericArguments.Arg1 = item;

var current = Sorter;

queue.Add(() => Task.Factory.StartNew(swf =>

{

try

{

FillWorkQueueWorkerFactory(swf as MutableTupleFactory<TWorker>, current);

}

catch (Exception e)

{

Exceptions.Add(e);

}

}, shallowWorkerFactory, Options.CancellationToken, Options.CreationOptions, Options.Scheduler));

Sorter++;

}

}

protected abstract void FillWorkQueueWorkerFactory<TWorker>(MutableTupleFactory<TWorker> worker, long sorter) where TWorker : MutableTuple<TSource>;

}