Resultados da pesquisa a pedido "parallel-processing"

1 a resposta

No Apache Spark, posso repetir / aninhar facilmente um SparkContext.parallelize?

Estou tentando modelar um problema de genética que estamos tentando resolver, construindo-o em etapas. Posso executar com êxito os exemplos PiAverage a partir de Spark Examples. Esse exemplo "lança dardos" em um círculo (10 ^ 6 no nosso caso) e ...

3 a resposta

Java: paralelizando a classificação rápida via multi-threading

Estou experimentando algoritmos de paralelização em Java. Comecei com a classificação por mesclagem e publiquei minha tentativa nestePergunta, questão [https://stackoverflow.com/questions/2879955/parallel-processing-via-multithreading-in-java] . ...

3 a resposta

Paralelações de aninhamento no Spark? Qual é a abordagem correta?

PARALELIZAÇÕES NESTADAS? Digamos que estou tentando fazer o equivalente a "aninhado para loops" no Spark. Algo como em uma linguagem regular, digamos que eu tenha uma rotina no loop interno que calcule Pi da maneirao exemplo do Pi Average Spark ...

3 a resposta

Por que o fluxo paralelo Files.list () está executando muito mais lentamente do que usando Collection.parallelStream ()?

O fragmento de código a seguir faz parte de um método que obtém uma listagem de diretório, chama um método de extração em cada arquivo e serializa o objeto de droga resultante para xml. try(Stream<Path> paths = Files.list(infoDir)) { paths ...

5 a resposta

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 ...

1 a resposta

MPI_Gather 2D array

N é 4, então éN_glob. Acontece que é do mesmo tamanho.p é 4. Aqui está uma pequena parte do código: float **global_grid; float **gridPtr; lengthSubN = N/pSqrt; subN = lengthSubN + 2; grid = allocate2D(grid, subN, subN); .. ...

2 a resposta

Diferença entre Iterator e Spliterator em Java8

Eu vim a conhecer enquanto estudava issoParallelism é uma vantagem principal deSpliterator. Esta pode ser uma pergunta básica, mas alguém pode me explicar as principais diferenças entreIterator eSpliterator e dar alguns exemplos?

2 a resposta

Qual é a diferença entre programação assíncrona e multithreading?

Eu pensei que eles eram basicamente a mesma coisa - escrever programas que dividem tarefas entre processadores (em máquinas com mais de 2 processadores). Então eu estou ...

2 a resposta

Problema com Invoke para paralelizar foreach

Estou com um problema ao usar System.Threading.Tasks.Parallel.ForEach. O corpo para cada progressBar deseja atualizar. Mas o método Invoke algumas vezes congela. Anexo o código ao formulário prograssbar e Buton. private void ...

1 a resposta

r paralelo com foreach e mclapply ao mesmo tempo

Estou implementando um sistema de processamento paralelo que eventualmente será implantado em um cluster, mas estou tendo problemas para descobrir como os vários métodos de processamento paralelo interagem. Eu preciso usar um loop for para ...