Cantidad de Threads al mismo tiempo

[carvear]

Hola, quería saber si alguien sabe cuantos threads al mismo tiempo se pueden crear, ya que necesito utilizar 1.000.000 para que para cada numero menor a un millón realice un calculo preciso.
Para cada numero verifico si es un primo, pero obtengo siempre outofMemory!
Aclaro, esto pasa desde que uso threads, la aplicación anda bien y mas RAPIDO sin threads, ademas de que no se cuelga.

Gracias

[carvear]

Ahora me surge la duda, si vos tuvieras que realizar el mismo calculo para 1.000.000 de numeros (un calculo para el 1, uno para el 2, uno para el 3 y asi (Siempre el mismo calculo)) deberia tener un hilo por cada ejecucion para cada numero? o Es un solo hilo?

[Kritik]

flipante, quieres crear una aplicación para saber si el nº 1 es un número primo, una aplicación distinta para el 2, otra distinta para el 3...

No sería mucho mejor hacer una única aplicación que te diga si el número introducido es primo o no? O si quieres una lista de números primos desde el 1 hasta el 1.000.000... pues que con una única aplicación te los fuese listando?

A ver si con este código te haces una idea...

public boolean esPrimo(int numero) {
int aux;
for(int cont=2;cont<numero/2;cont++){
aux=numero%cont;
if(aux==0) return false;
}
return true;
}

[Xerelo]

La verdad es que ni idea de cuál será el límite, pero un programa que necesita 1.000.000 de hilos paralelos, o es para la Nasa o el CERN, o está muy mal diseñado.

Una de las cosas que más me gusta de escribir en foros es que muchas veces me hacéis buscar cosas que nunca se me hubieran ocurrido.

http://java.dzone.com/articles/java-...number-threads

El código del programa dependerá de qué quieres que haga el programa y de cómo se va a usar. Si eres un poco más explícito, igual te pueden aconsejar mejor.

[carvear]

A ver, tengo el codigo orientado a objetos, con una clase Primo que tiene el metodo es_primo, anda muy bien. Lo que se me pide es optimizar con Threads todos los primos del 2 al 1000000. Como Implementarian los Threads ahí entonces?

[Profesor_Falken]

Buenas,

Cada vez que creas un thread, esto tiene un importante coste a nivel de recursos, ya que cada thread tiene su propio heap y stack de ejecucion. Por eso se te queda sin memoria.

Por otro lado lo que intentas es muy ineficiente, ya que el numero de cores de tu maquina es limitado. Ten en cuenta que cuando ejecutas muchos threads sobre un mismo core, este tiene que estar cambiando de contexto constantemente (http://es.wikipedia.org/wiki/Cambio_de_contexto)

El uso de muchos threads esta bien cuando se quieren ejecutar muchas tareas concurrentes sin dejar bloqueado al usuario. Por ejemplo un servidor, si no utilizase hilos, solo podria procesar una peticion al mismo tiempo.

Sin embargo tu caso es distinto, ya que no quieres ejecutar muchas tareas sino dividir una sola muy pesada. Esta es la diferencia entre concurrencia y paralelismo.

Lo que deberias hacer para conseguir el mayor rendimiento posible es basarte en el numero de cores de tu maquina:

Código Java:

int cores = Runtime.getRuntime().availableProcessors();
 

Ese es el numero de thread optimo para tu calculo.

Por otro lado, debes dividir bien las tareas. No puedes asignar a cada thread de forma secuencial.
Por ejemplo si tienes 4 cores y haces esto:
Thread 1: de 1 a 250000
Thread 2: de 250001 a 500000
[...]
Es muy mala idea ya que el algoritmo de calculo de primos es de complejidad lineal (O(n)) y por tanto, a mayor valor de n mas va a tardar. Lo mejor es que vayas asignando a cada core pequenos packs a procesar y segun vayan terminando le asignas nuevos hasta terminar.

En cualquier caso, si usas Java 8, esta chupado:

Código Java:

/**
 *
 * @author Profesor_Falken
 */
public class ParallelIsPrime {
    private boolean isPrime(long n) {
        return n > 1 && rangeClosed(2, (long) sqrt(n)).noneMatch(divisor -> n % divisor == 0);
    }
    
    private void printPrimes() {
        long[] primos = range(1, 1_000_000).parallel().filter(this::isPrime).toArray();
        for (int i = 0; i<primos.length; i++) {
            System.out.println(primos[i]);
        }
    }
    
    public static void main(String[] args) {         
        new ParallelIsPrime().printPrimes();
    }
}
 

Un saludo