Pourquoi ce code Java n'utilise-t-il pas tous les cœurs CPU?

le code Java simple ci-joint devrait charger tout le noyau cpu disponible au démarrage avec les bons paramètres. Ainsi, par exemple, vous commencez avec

java VMTest 8 int 0

et il va démarrer 8 threads qui ne font rien d'autre que boucler et ajouter 2 à un entier. Quelque chose qui fonctionne dans les registres et qui n'alloue même pas de nouvelle mémoire.

le problème auquel nous sommes confrontés maintenant est que nous ne chargez une machine 24 core (AMD 2 sockets avec 12 core chacun), en exécutant ce programme simple (avec 24 threads bien sûr). Des choses semblables se produisent avec 2 programmes chaque 12 threads ou des machines plus petites.

ainsi notre soupçon est que la JVM (Sun JDK 6u20 sur Linux x64) ne se balance pas bien.

quelqu'voir des choses semblables ou a la possibilité d'exécuter et de le signaler si oui ou non il fonctionne bien sur sa machine (>= 8 cœurs seulement s'il vous plaît)? Des idées?

j'ai essayé cela sur Amazon EC2 avec 8 cœurs aussi, mais la machine virtuelle semble fonctionner différemment d'une vraie boîte, donc le chargement se comporte totalement étrange.

package com.test;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

public class VMTest
{
    public class IntTask implements Runnable 
    {
        @Override
        public void run()
        {
            int i = 0;

            while (true)
            {
                i = i + 2;
            }
        }
    }
    public class StringTask implements Runnable 
    {
        @Override
        public void run()
        {
            int i = 0;

            String s;
            while (true)
            {
                i++;
                s = "s" + Integer.valueOf(i);
            }
        }
    }
    public class ArrayTask implements Runnable 
    {
        private final int size; 
        public ArrayTask(int size)
        {
            this.size = size;
        }
        @Override
        public void run()
        {
            int i = 0;

            String[] s;
            while (true)
            {
                i++;
                s = new String[size];
            }
        }
    }

    public void doIt(String[] args) throws InterruptedException
    {
        final String command = args[1].trim();

        ExecutorService executor = Executors.newFixedThreadPool(Integer.valueOf(args[0]));
        for (int i = 0; i < Integer.valueOf(args[0]); i++)
        {
            Runnable runnable = null;
            if (command.equalsIgnoreCase("int"))
            {
                runnable = new IntTask();
            }
            else if (command.equalsIgnoreCase("string"))
            {
                runnable = new StringTask();
            }
            Future<?> submit = executor.submit(runnable);
        }
        executor.awaitTermination(1, TimeUnit.HOURS);
    }

    public static void main(String[] args) throws InterruptedException
    {
        if (args.length < 3)
        {
            System.err.println("Usage: VMTest threadCount taskDef size");
            System.err.println("threadCount: Number 1..n");
            System.err.println("taskDef: int string array");
            System.err.println("size: size of memory allocation for array, ");
            System.exit(-1);
        }

        new VMTest().doIt(args);
    }
}