如何在 DataFlow Block 中为每个线程创建对象，但不是每个请求的对象？

Posted 2023-03-31

【中文标题】如何在 DataFlow Block 中为每个线程创建对象，但不是每个请求的对象？

【英文标题】：How to create object per thread in DataFlow Block but not object per request?

【发布时间】：2021-07-20 04:01:03

【问题描述】：

我有一个代码示例

var options = new ExecutionDataflowBlockOptions();
var actionBlock = new ActionBlock<int>(async request=>
         var rand = new Ranodm();
         //do some stuff with request by using rand
,options);

这段代码的问题在于，在每个请求中我都必须创建新的rand 对象。有没有一种方法可以为每个线程定义一个rand 对象并在处理请求时重用同一个对象？

【问题讨论】：

是的，ThreadLocal<Random> 是解决方案。你可以看看这个：Correct way to use Random in multithread application

【参考方案1】：

感谢 Reed Copsey for the nice article 和 Theodor Zoulias 提醒您注意 ThreadLocal<T>。

新的 ThreadLocal 类为我们提供了一个强类型， 我们可以使用本地范围的对象来设置保持独立的数据 对于每个线程。这允许我们使用每个线程存储的数据， 无需在我们的类型中引入静态变量。 在内部，ThreadLocal 实例将自动设置 静态数据，管理其生命周期，进行所有的转换 我们的特定类型。这使得开发变得更加简单。

A msdn example:

 // Demonstrates:
    //      ThreadLocal(T) constructor
    //      ThreadLocal(T).Value
    //      One usage of ThreadLocal(T)
    static void Main()
    
        // Thread-Local variable that yields a name for a thread
        ThreadLocal<string> ThreadName = new ThreadLocal<string>(() =>
        
            return "Thread" + Thread.CurrentThread.ManagedThreadId;
        );

        // Action that prints out ThreadName for the current thread
        Action action = () =>
        
            // If ThreadName.IsValueCreated is true, it means that we are not the
            // first action to run on this thread.
            bool repeat = ThreadName.IsValueCreated;

            Console.WriteLine("ThreadName = 0 1", ThreadName.Value, repeat ? "(repeat)" : "");
        ;

        // Launch eight of them.  On 4 cores or less, you should see some repeat ThreadNames
        Parallel.Invoke(action, action, action, action, action, action, action, action);

        // Dispose when you are done
        ThreadName.Dispose();
    

所以你的代码会是这样的：

ThreadLocal<Random> ThreadName = new ThreadLocal<Random>(() =>

    return new Random();
);


var options = new ExecutionDataflowBlockOptions

    MaxDegreeOfParallelism = 4,
    EnsureOrdered = false,
    BoundedCapacity = 4 * 8
;
var actionBlock = new ActionBlock<int>(async request =>

    bool repeat = ThreadName.IsValueCreated;
    var random = ThreadName.Value; // your local random class
    Console.WriteLine($"Thread: Thread.CurrentThread.ManagedThreadId,  
        repeat: ", repeat ? "(repeat)" : "");

 , options);