草庐IT

任务队列

全部标签

c# - Webjobs 会自动续订 Azure 队列消息的租约吗?

当Webjobs通过QueueTrigger从Azure存储上的队列获取消息时,它会租用该消息(使其不可见)。如果(webjob的)触发函数需要很长时间来处理消息,这个租约是否会自动延长?或者我应该在函数中处理它?在这个链接上WindowsAzureQueues:ImprovedLeases,ProgressTracking,andSchedulingofFutureWork,作者声明“执行原始出列的工作人员可以延长消息的租约,以便它可以继续处理消息”注意:我尝试了一个等待20分钟的网络作业(使用QueueTrigger)。//WriteLogThread.Sleep(1200000)

c# - 在执行长时间运行的数据库任务时处理 Web 服务超时

我们其中一款产品的架构是典型的3层解决方案:C#客户端WCF网络服务SQLServer数据库客户端从网络服务请求信息。Web服务访问数据库以获取信息并将其返回给客户端。问题来了。其中一些查询可能需要很长时间,而且我们事先不知道哪些查询会很慢。我们知道有些请求通常比其他请求慢,但如果有足够的数据,即使是最简单的请求也可能很慢。有时使用查询或运行大量数据的报告。在大量数据减慢查询速度之前,查询只能优化到目前为止。如果数据库中的查询达到SQLServer中的最大查询超时,数据库查询将终止,Web服务将错误返回给客户端。这是明白的。我们可以处理这些错误。客户端正在等待网络服务调用完成。如果数据

c# - MSMQ 一个(队列)到多个(监听器)场景

我有这样的场景:一个客户端将一条消息发送到一个msmq队列实例中,并且有3个进程在监听这个队列。我希望能够让这些实例中的每一个都选择不同的消息并进行处理。我知道这是队列的常见使用场景,我已经使用MSMQ、.NET和C#编写了工作代码。但是我想知道msmq是否是我在这里的最佳选择-文档明确指出MSMQ用于“一对一”通信,这意味着不应该有一个以上的监听器。这让我想知道,我正在为我的用例做正确的解决方案吗?或者反过来,我是否必须为每个监听器创建一个队列并在工作流的前面部分分发消息?非常感谢提供指向演示MSMQ在此类场景中的用法的工作示例的链接。谢谢 最佳答案

c# - 通过构建器模式使用异步任务

我目前使用构建器模式构建我的MVCView模型。varviewModel=builder.WithCarousel(),.WithFeaturedItems(3),.Build()我遇到的问题是当我必须对异步方法进行服务调用时。这意味着我的构建器方法必须返回Task而不是HomeViewModelBuilder.这阻止了我必须链接构建方法await他们。示例方法publicasyncTaskWithCarousel(){varcarouselItems=await_service.GetAsync();_viewModel.Carousel=carouselItems;returnth

c# - 使用 BlockingCollection 作为消息队列的响应式(Reactive)框架

我最近一直在使用ReactiveFramework做一些工作,到目前为止我非常喜欢它。我正在考虑用一些过滤的IObservables替换传统的轮询消息队列来清理我的服务器操作。在过去,我处理进入服务器的消息是这样的://StartspinningtheprocessmessageloopTask.Factory.StartNew(()=>{while(true){Commandcommand=m_CommandQueue.Take();ProcessMessage(command);}},TaskCreationOptions.LongRunning);这导致连续轮询线程将来自客户端的

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

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

c# - 异步任务<IEnumerable<T>> 抛出 "is not an iterator interface type"错误

仅当我使用async时,下面的代码才会抛出isnotaniteratorinterfacetypeawait并包装IEnumerable与任务。如果我删除asyncawait,它将与IEnumerable>一起使用.privateasyncTask>>GetTableDataAsync(CloudTablecloudTable,TableQuerytableQuery)whereT:ITableEntity,new(){TableContinuationTokencontineousToken=null;do{varcurrentSegment=awaitGetAzureTableDa

c# - 从任务回调到主线程

因为我不太了解线程,所以我有一个问题。我想在后台和后台方法中做一些事情,我想在某些情况下切换回主线程,否则在后台工作。我怎样才能实现这个功能?我正在使用从UI类(c#)调用StartSyncThreadasyncvoidStartSyncThread(){awaitDoSyncAsync();}TaskDoSyncAsync(){returnTask.Run(()=>DoSync());}在DoSync方法中,我想切换回主线程,以便我可以更改UI。请给我一个简单的解决方案来做到这一点。提前致谢! 最佳答案 首先启动您的异步进程,然后

c# - 在 C# 中实现阻塞队列

我使用下面的代码来实现和测试阻塞队列。我通过启动5个并发线程(移除器)从队列中拉出项目来测试队列,如果队列为空则阻塞,并启动1个并发线程(加法器)间歇性地将项目添加到队列中。但是,如果我让它运行足够长的时间,我会得到一个异常,因为即使队列为空,移除线程之一也会退出等待状态。有谁知道为什么我得到异常?请注意,我很想知道为什么这与有效的解决方案不同(因为我可以谷歌搜索)。非常感谢您的帮助。usingSystem;usingSystem.Threading;usingSystem.Collections.Generic;namespaceCode{classQueue{privateList

c# - 启动长时间后台任务

用户在我的网站上请求一些页面。我想做什么?向用户发送快速答复并启动需要很长时间的后台任务。看起来像:publicActionResultindex(){vartask=newTask(Stuff);//starttaskasynctask.start();returnView();}publicvoidStuff(){//longtimeoperation}我该怎么做? 最佳答案 您可以向TaskStartNew()方法传递一个参数,指示您正在启动的任务是“长时间运行”的,这会提示任务计划程序在新线程上启动任务。vartask=Ta