Para modificar a coleção dentro da função onmessage
, você precisa utilizar uma referência a própria coleção (self), ao invés da variável 'result'
:
self[event.data[0]] = event.data[1];
Apenas para complementar a resposta:
O método Parallel.ForEach no framework .NET executa um processamento em cada um dos elementos de um array (map) e esse processamento pode ou não ser feito utilizando paralelismo.
No momento da execução do método, o .NET avalia os recursos disponíveis (ex: número de processadores e memória) e a quantidade de processamento disponível na máquina para determinar se:
- vale a pena ou não executar a operação map em paralelo
- em quantas threads o trabalho será divido (caso haja vantagem no paralelismo)
Supondo que o seu código Javascript seja executado em uma página web, você não tem como acessar todas essas informações do sistema para decidir se vale a pena a execução paralela.
Mesmo se você preferir 'forçar' a execução paralela, você precisa determinar quantas threads irão executar o serviço e, para isso, você precisará saber, por exemplo, quantos processadores (físicos e lógicos) estão disponíveis no sistema, pois caso o número de threads ultrapasse o número de núcleos disponiveis, pode haver perda de desempenho.
No seu código, você está criando uma thread por elemento do array e, provavelmente, isso vai reduzir o desempenho, pois o esforço para criar as threads será muito maior que o ganho com o processamento paralelo.
Uma solução comum para esse tipo de implementação é criar um pool de threads e dividir o array em partes, que serão processadas separadamente em cada thread.
No método onmessage
, o código do pool recolhe os resultados e atualiza os elementos do array.
Após a execução da última thread, você chama o callback finish
.
Um ponto importante que precisa ser avaliado também é que a comunicação entre a thread principal e os Workers é feita através da cópia dos parâmetros e não por referência, e isso pode gerar perda de desempenho dependendo do algoritmo que você irá implementar.
Segue abaixo, um exemplo comentado de implementação desse conceito com um pool de 4 threads, porém, não recomendo o uso desse código em nenhum ambiente de produção.
Uma sugestão para você testar os conceitos acima, é você implementar um "cronômetro" e fazer diversos testes com tamanhos de arrays diferentes (pequeno, médio, gigante), com números de threads diferentes e, se possível, em máquinas diferentes (com quantidades de processadores diferentes) para observar o comportamento e o desempenho da implementação.
// Determina o número de threads no pool
var NUMERO_DE_THREADS = 4
// Cria o método parallelMap
Array.prototype.parallelMap = function (callback, finish) {
var self = this;
// Pool de threads
var pool = [];
// Status da thread. false => já terminou o trabalho
var status = [];
// Corpo do objeto Worker
var source = "onmessage = " + function (event) {
// Posição no array
var posicao = event.data[0];
// Trecho do array a ser processado
var dados = event.data[1];
// Callback de processamento
eval("var cb = " + event.data[2]);
// ID da thread
var id = event.data[3]
// Efetua o processamento do trecho do array
for (var i=0; i<dados.length; i++)
dados[i] = cb(dados[i], i);
// Retorna o resultado
postMessage([id, posicao, dados]);
// Finaliza o Worker
close();
}.toString();
var blob = new Blob([source], { type: 'text/javascript' });
var _url = URL.createObjectURL(blob);
// Cria um pool de workers
for (var i=0; i<NUMERO_DE_THREADS; i++) {
// Seta o status do worker como true => trabalhando
status[i] = true;
// Cria o Worker
pool[i] = new Worker(_url);
// Processa o retorno do Worker
pool[i].onmessage = function(e) {
var id = e.data[0];
var posicao = e.data[1];
var resultado = e.data[2];
// Atualiza o array com os resultados
for (var j=0; j<resultado.length; j++)
self[posicao+j] = resultado[j];
// Sinaliza que este Worker terminou o trabalho
status[id] = false;
// Retorna se algum Worker ainda estiver trabalhando
for (var j=0; j<NUMERO_DE_THREADS; j++)
if (status[j])
return;
// Todos terminaram o trabalho, chama o callback finish
finish(self);
}
}
// Calcula o tamanho do trabalho de cada Worker, divindo o tamanho
// do array pelo número de threads
var tamanhoDoTrabalho = Math.floor(self.length / NUMERO_DE_THREADS);
// Inicia o trabalho do pool e envia cada parte do array para
// um Worker
var posicao = 0;
for (var i=0; i<NUMERO_DE_THREADS; i++) {
var trabalho;
if (i<NUMERO_DE_THREADS-1)
trabalho = self.slice(posicao, posicao+tamanhoDoTrabalho);
else
trabalho = self.slice(posicao);
pool[i].postMessage([posicao, trabalho, callback.toString(), i]);
posicao += tamanhoDoTrabalho;
};
}
var numeros = [7, 2, 4, 6, 8, 1, 3, 5, 7, 9];
numeros.parallelMap(function (numero, indice) {
return numero + Math.random()*200;
}
, function (resultado) {
console.log(resultado); // os valores da coleção numeros deveriam está alterados neste ponto.
}
);
Atualização:
Em resposta ao comentário sobre não utilizar o return
dentro do callback, neste caso é necessário acessar o elemento do array através do parâmetro indice
, pois o elemento não é passado por referência para a função callback, portanto, não pode ser atualizado diretamente.
Alterando a linha:
dados[i] = cb(dados[i], i);
Para:
cb(dados, i);
A função callback
não precisará do return
.
Assim, a chamada da função parallelMap
fica da seguinte forma:
numeros.parallelMap(function (numero, indice) {
numero[indice] += Math.random()*200;
}
, function (resultado) {
console.log(resultado);
}
);
Bibliotecas para execução paralela em Javascript:
Parallel.js - Parallel Computing with Javascript
Hamsters.js | Parallel Javascript
threads.js
Inline Worker
parallelForEach
a coleção seja modificada? Ou a funçãoparallelMap
não está passando para o callback a coleção modificada?parallelMap
está ok, o problema aqui é modificar a coleção noparallelForEach