草庐IT

task-parallel-library

全部标签

c# - 静态初始化器中的 Task.Run

考虑以下代码。staticclassX{publicstaticintValue=Task.Run(()=>0).Result;}classProgram{staticvoidMain(string[]args){varvalue=X.Value;}}调用Task.Run然后在静态初始化程序中调用Result会导致程序永久卡住。为什么? 最佳答案 您在CLR的类初始化锁上看到了死锁。基本上,课上什么都没有X可以在类初始化之前使用。但是你的匿名方法()=>0被编译为该类的成员。在Task之前,类初始化不会完成可以完成,但是Task无法

c# - C#中的并行树遍历

我需要快速遍历一棵树,我想并行进行。我宁愿使用并行扩展,也不愿手动启动一堆线程。我当前的代码看起来像这样:publicvoidTraverse(Noderoot){varnodeQueue=newQueue();nodeQueue.Enqueue(root);while(nodeQueue.Count!=0){varnode=nodeQueue.Dequeue();if(node.Property=someValue)DoSomething(node);foreach(varnodeinnode.Children){nodeQueue.Enqueue(node);}}}我真的希望Par

c# - Parallel.Foreach 与正常 ForEach 一样快/慢

更新:我使用线程在内核数量(在我的案例中为8个)中拆分循环,并且整个循环在不到1秒的时间内完成。所以问题不在于,使用线程操作不会更快。为什么ParralelExtension在这种情况下会失败?大家好。我想用Parrallel.Foreach转换我的ForEach。问题是,并行化几乎没有给我带来任何好处。原文:foreach(Entities.Buchungbuchunginbuchungen){Int32categoryID=manager.GetCategoryID(newRegelengine.Booking(buchung));//Average4msbuchung.Categ

c# - 具有指定结果的任务并行库 WaitAny

我正在尝试编写一些代码来并行调用多个不同服务器的Web服务,因此TPL似乎是显而易见的选择。我的Web服务调用中只有一个会返回我想要的结果,而其他所有调用都不会。我正在尝试找到一种有效地拥有Task.WaitAny的方法,但只有在第一个匹配条件的Task返回时才解除阻塞。我尝试使用WaitAny但无法确定过滤器的放置位置。我做到了这一点:publicvoidSearchServers(){varservers=new[]{"server1","server2","server3","server4"};vartasks=servers.Select(s=>Task.Factory.St

c# - Task.Run 和 Task.Factory.StartNew 之间不同的异常处理

我在使用Task.Factory.StartNew并trycatch抛出的exception时遇到问题。在我的应用程序中,我有一个长时间运行的任务,我想将其封装在Task.Factory.StartNew(..,TaskCreationOptions.LongRunning);但是,当我使用Task.Factory.StartNew时,异常没有被捕获。然而,当我使用Task.Run时,它的工作方式与我预期的一样,我认为它只是Task.Factory.StartNew的包装器(根据例如thisMSDNarticle).此处提供了一个工作示例,不同之处在于使用Task.Run时将异常写入控

c# - 无法添加对 'Microsoft Windows Installer Object Library' 的引用

我无法使用VS2012添加对“MicrosoftWindows安装程序对象库”的引用。任何想法,什么可能导致这个问题?当我尝试创建对COM组件的引用时,我收到此错误消息“无法添加对‘MicrosoftWindowsInstallerObjectLibrary’的引用”。VS工程为基础类库(c#x86) 最佳答案 在VisualStudio中转到引用>添加引用...>COM>浏览...>%WINDIR%\system32\msi.dll。在VS2012上为我工作。 关于c#-无法添加对'M

c# - 无法将类型 'bool' 隐式转换为 'system.threading.tasks.task bool'

我在服务实现代码中遇到此错误:“无法将类型‘bool’隐式转换为‘system.threading.tasks.taskbool’”。你能更正我的代码吗?publicTasklogin(stringusn,stringpwd){DataClasses1DataContextauth=newDataClasses1DataContext();varmessage=frompinauth.Userswherep.usrName==usn&&p.usrPass==pwdselectp;if(message.Count()>0){returntrue;}else{returnfalse;}}

c# - 强制调用一次异步方法

假设我有一个类需要使用InitializeAsync()方法执行一些异步初始化。我想确保只执行一次初始化。如果另一个线程在初始化过程中调用此方法,它将“等待”直到第一个调用返回。我正在考虑以下实现(使用SemaphoreSlim)。有更好/更简单的方法吗?publicclassMyService:IMyService{privatereadonlySemaphoreSlimmSemaphore=newSemaphoreSlim(1,1);privateboolmIsInitialized;publicasyncTaskInitializeAsync(){if(!mIsInitializ

c# - 带有 CancellationTokenSource 的 Task.Factory.FromAsync

我有以下代码行用于从NetworkStream异步读取:intbytesRead=awaitTask.Factory.FromAsync(this.stream.BeginRead,this.stream.EndRead,buffer,0,buffer.Length,null);我想让它支持取消。我知道我可以canceltasksusingaCancellationTokenSource,但是我看不出有什么方法可以将它传递给TaskFactory.FromAsync().是否可以使FromAsync()构造的任务支持取消?编辑:我想取消一个已经在运行的任务。

c# - 将任务作为参数传递

我不确定这是否可行,所以我在这里:我有一系列Action可以执行多个asyncTaskMethodA(...){//somecode//acalltospecificAsyncIOboundmethod//somecode}还有MethodB()、MethodC()等,除了调用特定的AsyncIO绑定(bind)方法外,它们的代码完全相同.我正在尝试找到一种将任务指针传递给方法的方法,以便我们稍后可以在Method()中执行它。我目前正在做的是:privateasyncTaskMethod(Func>func){//somecodevara=awaittask.Run(func);//