Как запустить один процесс для нескольких значений в C #?

Question

Как запустить один процесс для нескольких значений в C #?

В Java все переменные, которые вы объявляете, на самом деле являются «ссылками» на объекты (или примитивы), а не самими объектами.

При попытке выполнить один метод объекта , ссылка просит живой объект выполнить этот метод. Но если ссылка ссылается на NULL (ничего, нуль, void, nada), то нет способа, которым метод будет выполнен. Тогда runtime сообщит вам об этом, выбросив исключение NullPointerException.

Ваша ссылка «указывает» на нуль, таким образом, «Null -> Pointer».

Объект живет в памяти виртуальной машины пространство и единственный способ доступа к нему - использовать ссылки this. Возьмем этот пример:

public class Some {
    private int id;
    public int getId(){
        return this.id;
    }
    public setId( int newId ) {
        this.id = newId;
    }
}

И в другом месте вашего кода:

Some reference = new Some();    // Point to a new object of type Some()
Some otherReference = null;     // Initiallly this points to NULL

reference.setId( 1 );           // Execute setId method, now private var id is 1

System.out.println( reference.getId() ); // Prints 1 to the console

otherReference = reference      // Now they both point to the only object.

reference = null;               // "reference" now point to null.

// But "otherReference" still point to the "real" object so this print 1 too...
System.out.println( otherReference.getId() );

// Guess what will happen
System.out.println( reference.getId() ); // :S Throws NullPointerException because "reference" is pointing to NULL remember...

Это важно знать - когда больше нет ссылок на объект (в пример выше, когда reference и otherReference оба указывают на null), тогда объект «недоступен». Мы не можем работать с ним, поэтому этот объект готов к сбору мусора, и в какой-то момент VM освободит память, используемую этим объектом, и выделит другую.

1

c# multithreading linq parallel-processing task

задан Aderbal Farias 11 April 2019 в 09:49

4 ответа

Другие вопросы по тегам:

c# multithreading linq parallel-processing task

Похожие вопросы:

score 0 · Answer 1

Во-первых, я бы использовал одновременную коллекцию ConcurrentBag в этом случае (если вы пишете в коллекцию). Параллельные коллекции блокируют экземпляр, когда несколько потоков собираются получить к нему доступ. Также я бы предложил использовать Task.WhenAll с ключевым словом await. Task.WaitAll может создать тупик. Вот пример, который вы можете попробовать:

public static async Task Main()
{
    var symbolList = new ConcurrentBag<string> { "AAPL", "QQQ", "FB", "MSFT", "IBM" };
    var taskArray = new List<Task>();

    foreach (var s in symbolList)
    {
        var task = Task.Run(() =>
        {
            Process(s);
        });

        taskArray.Add(task);
    }

    await Task.WhenAll(taskArray);
}

score 0 · Answer 2

Parallel.Foreach могут сделать это. Вот пример того, как:

public static void DoIt(string a)
{
    Console.WriteLine(a);
}

public static void Main(string[] args)
{
    List<string> symbolList = new List<string>() { "AAPL", "QQQ", "FB", "MSFT", "IBM" };
    Parallel.ForEach(symbolList, a => DoIt(a));
}

Вы можете управлять вызовом с помощью ParallelOptions:

ParallelOptions options = new ParallelOptions() { MaxDegreeOfParallelism = 10 };
Parallel.ForEach(symbolList, options, a => DoIt(a));

score 0 · Answer 3

Возможно, вам следует заменить:

symbolList.IndexOf(i)

... на:

symbolList[i]

0

ответ дан Theodor Zoulias 11 April 2019 в 09:49

score 0 · Answer 4

Помимо того, что у вас есть недопустимый код (symbolList.IndexOf(i), вероятно, должно быть symbolList[i]), проблема, с которой вы сталкиваетесь, заключается в том, что вы не захватываете переменную цикла, прежде чем вызывать лямбду.

Вот простое исправление:

List<string> symbolList = new List<string>() { "AAPL", "QQQ", "FB", "MSFT", "IBM" };
Task[] taskArray = new Task[symbolList.Count];
for (int i = 0; i < taskArray.Length; i++)
{
    string symbol = symbolList[i];
    taskArray[i] = Task.Factory.StartNew(() =>
    {
        criteriaEvalution.Evaluate(finalArray, false, new List<parseObj>(), ref builder, symbol);
    });
}
Task.WaitAll(taskArray);

Обратите внимание на строку string symbol = symbolList[i];, прежде чем начать задание.

Если вы этого не сделаете, цикл завершится до запуска задач, а затем i будет равен taskArray.Length, и, следовательно, вы получите ошибку «Индекс был вне диапазона».

Другое, что я хотел бы предложить, это то, что вы должны использовать Microsoft Reactive Framework (он же Rx) - NuGet System.Reactive и добавить using System.Reactive.Linq; - тогда вы можете сделать это:

List<string> symbolList = new List<string>() { "AAPL", "QQQ", "FB", "MSFT", "IBM" };

var query =
    from symbol in symbolList.ToObservable()
    from e in Observable.Start(() =>
        criteriaEvalution.Evaluate(finalArray, false, new List<parseObj>(), ref builder, symbol))
    select e;

query.ToArray().Wait();

Гораздо проще и чище, чем задачи. Затем вы можете использовать операторы LINQ для результатов.