Resultados da pesquisa a pedido "task-parallel-library"
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 { ...
Como implementar Task.WhenAny () com um predicado [fechado]
Desejo executar várias tarefas de forma assíncrona, cada tarefa executará uma solicitação http que pode gerar uma exceção ou terminar com segurança. preciso terminar quando a primeira tarefa for concluída com êxito ou quando todas as tarefas ...
Como obter o paralelismo máximo e utilizar a CPU máxima com o Parallel.ForEach?
Existe uma função C #A(arg1, arg2) que precisa ser chamado muitas vezes. Para fazer isso mais rápido, estou usando programação paralela. Veja o exemplo do seguinte código: long totalCalls = 2000000; int threads = ...
Esperando que uma única tarefa falhe fora de uma Lista <Tarefa <.. >> mais limpa, possivelmente com o LINQ?
Na minha inscrição, tenho umList<Task<Boolean>> que euTask.Wait[..] para determinar se eles foram concluídos com êxito (Result = true) Embora se durante a minha espera umTask completa e retorna um valor falsey eu quero cancelar todos os ...
Quando uma tarefa deve ser considerada "de longa duração"?
Ao trabalhar com tarefas, uma regra geral parece ser o pool de encadeamentos - normalmente usado por ex. invocandoTask.Run()ouParallel.Invoke() - deve ser usado pararelativamente curto operações. Ao trabalhar com operações de longa execução, ...
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 ...
Execução paralela para operações vinculadas de E / S
Eu li os documentos TPL e da biblioteca de tarefas, de capa a capa. Mas ainda não consegui compreender o caso a seguir com muita clareza e agora preciso implementá-lo. Vou simplificar minha situação. eu tenho umIEnumerable<Uri> de comprimento ...
O que determina o número de encadeamentos para trabalhos gerados e gerados pelo TaskFactory?
Eu tenho o seguinte código: var factory = new TaskFactory(); for (int i = 0; i < 100; i++) { var i1 = i; factory.StartNew(() => foo(i1)); } static void foo(int i) { Thread.Sleep(1000); Console.WriteLine($"foo{i} - on thread ...
Por que esse código paralelo é mais lento que sua versão não paralela semelhante?
Eu tenho o seguinte código (copiado aqui do LINQPad). Obviamente, parece que eu não estou entendendo como o TPL funciona ou o código é lixo. Por que a versão paralela é mais lenta que a versão não paralela? for (int i = 0; i < 100; i++) { ...
Como posso ler mensagens de uma fila em paralelo?
SituaçãoTemos uma fila de mensagens. Gostaríamos de processar mensagens em paralelo e limitar o número de mensagens processadas simultaneamente. Nosso código de avaliação abaixo processa mensagens em paralelo, mas só inicia um novo lote de ...