Начиная Producer-Tasks с называемого метода?

Question

Я новичок в Задачах и должен решить проблему здесь.Я постоянно получаю int и float (примерно каждые 10 мс), которые первоначально отфильтровываются из постоянного потока данных, а затем обрабатываются различными алгоритмами.Я хочу объединить их в BlockingCollection, чтобы иметь шаблон ConsumerProducer для дальнейшей обработки этих данных.Я хочу запустить несколько производителей и потребителей, но я застрял здесь, так как не знаю, как обращаться с этим постоянным потоком данных.Мой подход такой:

public void Store(int iChannel, float fValue)
{
    producer = new Task(() => { BundleAndPutOnMyBlockingCollection(iChannel, fValue);
}

... очевидно, что это дает мне множество задач, как постоянно вызывается Store ().Я попытался с mytask.status, чтобы сделать обработку, но не удалось.Может кто-нибудь дать мне подсказку, как справиться с этой проблемой?Лучше всего иметь масштабируемое количество задач для производства, например, 100 для тестирования.Спасибо.

Answer 1

Ну, вы никогда не запускаете задачи, так что ничто никогда не попадет в блокирующую коллекцию таким образом ... но мне не совсем понятно, зачем вам вообще нужна задача здесь , Почему ваш Store метод просто не добавляет его непосредственно в коллекцию блокировок? Возможно, вы захотите задание для потребителя , но это другое дело.