TPL локальное хранилище данных или что-то в этом роде

Question

Что я пытаюсь выполнить, так это у меня есть блок действий с MaxDegreeOfParallelism = 4. Я хочу создать один локальный экземпляр объекта сеанса, который у меня есть для каждого параллельного пути. Поэтому я хочу суммировать 4 объекта сеанса. Если бы это было тема, я хотел бы создать что-то вроде:

ThreadLocal<Session> sessionPerThread = new ThreadLocal<Session>(() => new Session()); 

Я знаю, что блоки не являются нитями, так я ищу что-то подобное, но для блоков. Любой способ создать это?

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

Примечание: приведенный выше ответ недействителен для того, что я прошу. Я специально прошу что-то другое, чем thread local, и выше ответ использует thread local. Это совсем другой вопрос.

Answer 1

Как вы уже знаете, блоки потока данных абсолютно не гарантируют корреляцию между блоками, исполнением и потоками. Даже при максимальном параллелизме, установленном в 4, все 4 задачи могут выполняться в одном и том же потоке. Или отдельная задача может выполняться во многих потоках.

Учитывая, что вы в конечном итоге хотите использовать п экземпляров дорогого сервиса для п степени параллелизма, давайте рассмотрим поток данных полностью из картины на минуту, так как это не помогает (или непосредственно препятствовать) от любого общего решения этой проблемы. На самом деле это довольно просто. Вы можете использовать ConcurrentStack<T>, где T - тип вашего сервиса, который стоит создавать. У вас есть код, который появляется в верхней части метода (или делегат), который представляет одну из ваших параллельных единиц работы:

private ConcurrentStack<T> reusableServices; 

private void DoWork() { 
    T service; 
    if (!this.reusableServices.TryPop(out service)) { 
     service = new T(); // expensive construction 
    } 

    // Use your shared service. 
    //// Code here. 

    // Put the service back when we're done with it so someone else can use it. 
    this.reusableServices.Push(service); 
} 

Теперь, таким образом, вы можете быстро увидеть, что вы создаете именно столько экземпляров вашего поскольку у вас есть параллельные исполнения DoWork(). Вам даже не нужно жестко кодировать степень параллелизма, которую вы ожидаете. И он ортогонален как вы фактически планируете этот параллелизм (поэтому threadpool, Dataflow, PLINQ и т. Д. Не имеет значения).

Таким образом, вы можете использовать DoWork() в качестве делегата блока потока данных, и вы готовы к работе.

Конечно, нет ничего волшебного в ConcurrentStack<T> здесь, за исключением того, что блокировки вокруг push и pop встроены в тип, поэтому вам не нужно это делать самостоятельно.