草庐IT

async_write

全部标签

c# - 使用 async/await 的异步 TcpListener 的正确方法

我一直在思考使用异步编程搭建TCP服务器的正确方式是什么。通常我会为每个传入请求生成一个线程,但我想使用ThreadPool的大部分内容,因此当连接空闲时,不会有阻塞的线程。首先,我会创建监听器并开始接受客户端,在本例中,是在控制台应用程序中:staticvoidMain(string[]args){CancellationTokenSourcecancellation=newCancellationTokenSource();varendpoint=newIPEndPoint(IPAddress.Parse("127.0.0.1"),8001);TcpListenerserver=n

c# - ASP.Net MVC 3 Razor Response.Write 位置

我正在尝试更新thistutorial关于将Facebook的BigPipe实现到Razor。有一个html帮助程序扩展,它可以将pagelet添加到列表中,然后将holdingdiv输出到响应中。这个想法是稍后将这个pagelet的内容呈现为一个字符串,然后通过javascript注入(inject)到这个holdingdiv中。publicstaticvoidRegisterPagelet(thisHtmlHelperhelper,Pageletpagelet){varcontext=helper.ViewContext.HttpContext;Listpagelets=(List

c# - ThreadPool 服务器的 async/await 等价物是什么?

我正在使用同步api和线程池在看起来像这样的tcp服务器上工作:TcpListenerlistener;voidServe(){while(true){varclient=listener.AcceptTcpClient();ThreadPool.QueueUserWorkItem(this.HandleConnection,client);//OralternativelynewThread(HandleConnection).Start(client)}}假设我的目标是以最低的资源使用率处理尽可能多的并发连接,这似乎很快就会受到可用线程数的限制。我怀疑通过使用非阻塞任务api,我将

c# - 为什么 Resharper 使用此代码说 "Co-variant array conversion from string[] to object[] can cause run-time exception on write operation"?

这个问题在这里已经有了答案:Co-variantarrayconversionfromxtoymaycauserun-timeexception(7个答案)关闭7年前。这段代码:comboBoxMonth.Items.AddRange(UsageRptConstsAndUtils.months.ToArray());publicstaticListmonths=newList{"Jan","Feb","Mar","Apr","May","Jun","Jul","Aug","Sep","Oct","Nov","Dec"};提示“从string[]到object[]的Co-variant数

c# - 将 Microsoft.Bcl.Async 与代码分析一起使用会导致错误

我正在尝试使用Microsoft.Bcl.Async和代码分析,但是当我运行代码分析时,出现一个或多个错误。我正在使用带有更新2的VisualStudio2012。这对我来说很容易重现:创建一个针对.Net4的新默认控制台应用程序。右键单击References,然后选择ManageNuGetPackages...单击Online并在SearchOnline框中键入async。您应该看到Asyncfor.NetFramework4...。点击安装并接受所有问题。向Main()添加一行内容:TaskEx.Delay(1000);和usingSystem.Threading.Tasks;转到

c# - C# (async ctp/.net 4.5) 中的异步递归是否安全?

在带有asyncctp或vs.net2011beta的C#中,我们可以像这样编写递归代码:publicasyncvoidAwaitSocket(){varsocket=awaitthis.AcceptSocketAsync();//awaitsocketand>>return在这个特定的示例中,代码异步等待一个tcp套接字,一旦它被接受,它将递归并异步等待另一个套接字。这似乎工作正常,因为await部分将使代码返回给调用者,因此不会导致堆栈溢出。这里有两个问题:如果我们忽略我们正在处理此示例中的套接字这一事实。以这种方式进行无栈递归可以吗?还是我缺少缺点?从IO的角度来看,上述代码是否

c# - Interlocked.Exchange 和 Volatile.Write 之间的区别?

Interlocked.Exchange和Volatile.Write有什么区别?这两种方法都会更新一些变量的值。有人可以总结一下何时使用它们吗?Interlocked.ExchangeVolatile.Write特别是我需要更新数组的double项,我希望另一个线程看到最新的值。什么是首选?Interlocked.Exchange(refarr[3],myValue)或Volatile.Write(refarr[3],info);其中arr是声明为double?真实的例子,我这​​样声明double数组:privatedouble[]_cachedProduct;在一个线程中,我这样

c# - 如何在 .NET 4.0 中使用 Microsoft.Bcl.Async 支持 TransactionScope 中的异步方法?

这个问题在这里已经有了答案:GetTransactionScopetoworkwithasync/await(4个答案)关闭2年前。我有一个类似的方法:publicasyncTaskSaveItemsAsync(IEnumerableitems){using(varts=newTransactionScope()){foreach(variteminitems){await_repository.SaveItemAsync(item);}await_repository.DoSomethingElse();ts.Complete();}}这当然有问题,因为TransactionScop

c# - 为什么 Enumerator.MoveNext 在与 using 和 async-await 一起使用时不能像我预期的那样工作?

我想通过一个List来枚举并调用异步方法。如果我这样做:publicasyncTaskNotWorking(){varlist=newList{1,2,3};using(varenumerator=list.GetEnumerator()){Trace.WriteLine(enumerator.MoveNext());Trace.WriteLine(enumerator.Current);awaitTask.Delay(100);}}结果是:True0但我希望它是:True1如果我删除using或awaitTask.Delay(100):publicvoidWorking1(){var

c# - 当我使用 "await" "async"方法时,它会变成同步的吗?

场景是这样的:staticasyncvoidMain(string[]args){awaitAnAsyncMethod();}privatestaticasynctaskAnAsyncMethod(){varx=awaitsomeAsyncMethod();vary=awaitsomeOtherAsyncMethod();returnx==y;}“someAsyncMethod”和“someOtherAsyncMethod”是因为我们使用await而同步运行,还是它们都按照执行顺序异步运行?更新鉴于下面的答案表明等待的异步方法将按顺序运行,如果我们只是要停止执行并等待这些方法的返回值,