C# asynchronous parallel-processing taskfactory

Task.Factory.StartNew“操作”参数和更高级别的局部变量

发布于 2024-10-05 14:01:25 字数 318 浏览 7 评论 0原文

考虑一下：

void StartUpdate(DataRequest dataRequest)
{
    Task.Factory.StartNew(request => {... do something with "request" ...}, 
        dataRequest);
}

现在，我的问题是：我可以在 lambda 表达式中使用 dataRequest，而不是将其作为第二个参数传递给 StartNew 方法吗？我担心的是 - 该方法将在不同的线程上执行，我不确定 dataRequest 在那里使用时是否会保持其状态。

原文

Consider this:

void StartUpdate(DataRequest dataRequest)
{
    Task.Factory.StartNew(request => {... do something with "request" ...}, 
        dataRequest);
}

Now, my question: can I use dataRequest inside the lambda expression, instead of passing it as second parameter to StartNew method? My concern is - that method will be executed on a different thread and I'm not sure if dataRequest would keep its state when used there.

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

佼人 2024-10-12 14:01:36

回答你的问题，你可以，但它可能不是线程安全的。我学习使用 ThreadLocal 来提供帮助。

在您的委托方法内部应该隔离您的 dataRequest。

ThreadLocal<DataRequest> tls = new ThreadLocal<DataRequest>();

Task.Factory.StartNew(request => {
   tls.Value = (DataRequest)stateObject;

   ///
}, dataRequest);

/* 我从 C# 中的 Pro .NET 并行编程 */

Answer to your question, You can but it may not threadsafe. I learn to use ThreadLocal to help.

inside your delegate method should Isolate your dataRequest.

ThreadLocal<DataRequest> tls = new ThreadLocal<DataRequest>();

Task.Factory.StartNew(request => {
   tls.Value = (DataRequest)stateObject;

   ///
}, dataRequest);

/* I get it from Pro .NET Parallel Programming in C# */

回复收藏 0 原文

以往的大感动 2024-10-12 14:01:35

我也有同样的问题。使用 Action 而不是 lambda 表达式。

private void StartUpdate(DataRequest dataRequest)
{
    Action<DataRequest> pobjAction = new Action<DataRequest>(DoSomething);
    Task.Factory.StartNew(pobjAccion, dataRequest);
}


private void DoSomething(DataRequest dataRequest)
{
    Trace.WriteLine(dataRequest.ToString());
}

I had the same problem. Use Action instead of the lambda expression.

private void StartUpdate(DataRequest dataRequest)
{
    Action<DataRequest> pobjAction = new Action<DataRequest>(DoSomething);
    Task.Factory.StartNew(pobjAccion, dataRequest);
}


private void DoSomething(DataRequest dataRequest)
{
    Trace.WriteLine(dataRequest.ToString());
}

回复收藏 0 原文