Fluxo de dados TPL x semáforo simples

Eu tenho um requisito para fazer um processo escalável. O processo possui principalmente operações de E / S com algumas operações menores da CPU (principalmente desserializando cadeias). O processo consulta o banco de dados em busca de uma lista ...

TPL Completo vs Conclusão

Preciso importar dados relacionados ao cliente do banco de dados herdado e executar várias transformações durante o processo. Isso significa que uma única entrada precisa executar "eventos" adicionais (sincronizar produtos, criar faturas ...

Por que os blocos são executados nessa ordem?

Este é um exemplo de código curto para apresentar rapidamente a você qual é a minha pergunta: using System; using System.Linq; using System.Threading.Tasks; using System.Threading.Tasks.Dataflow; namespace DataflowTest { class Program { ...

BatchBlock produz lote com elementos enviados após TriggerBatch ()

Eu tenho um pipeline de fluxo de dados que consiste em vários blocos. Quando os elementos fluem pelo meu pipeline de processamento, quero agrupá-los por campoA. Para fazer isso eu tenho umBatchBlock com altaBoundedCapacity. Nele, guardo ...

EventSourceException: nenhum buffer gratuito disponível no sistema operacional

O texto completo da exceção é: EventSourceException: nenhum buffer gratuito disponível no sistema operacional (por exemplo, taxa de eventos muito rápida). Estou chamando esse método aproximadamente um milhão de vezes por causa da recursão. Ele ...

Impasse BufferBlock com OutputAvailableAsync após TryReceiveAll

Enquanto trabalhavauma resposta [https://stackoverflow.com/a/25269043/885318] paraessa questão [https://stackoverflow.com/q/25251809/885318], Escrevi este trecho: var buffer = new BufferBlock<object>(); var producer = Task.Run(async () => ...

Raspagem paralela no .NET

A empresa em que trabalho administra algumas centenas de sites muito dinâmicos. Ele decidiu criar um mecanismo de pesquisa e fui encarregado de escrever o raspador. Alguns sites são executados em hardware antigo e não são capazes de sofrer muito ...

Repetir política dentro de ITargetBlock <TInput>

Eu preciso introduzir uma política de repetição no fluxo de trabalho. Vamos dizer que existem 3 blocos que estão conectados de tal maneira:

Task Dataflow, um bloco de dados pode ser alterado a partir do estado de conclusão?

Registo assíncrono lançando um NullReferenceException

Eu estou tentando assíncrona log algumas informações para o SQL Server dentro de uma ação de controlador MVC 4 visando o .NET 4.0 usando o AsyncTargetingPack...