Problèmes sporadiques dans la gestion d'un projet Java multi-thread à Win7

Je travaille sur un projet à la fois de la mémoire et de la calcul intensive. Une partie importante de l'exécution utilise la multi-threading par un fixeTheadpool code>. Bref; Je dispose 1 em> fil d'extraction de données à partir de plusieurs emplacements distants (à l'aide de connexions URL) et de remplir un blockingQueue code> avec des objets à analyser et n em> threads qui Choisissez ces objets et exécutez l'analyse. EDIT: voir le code ci-dessous strong>

Cette configuration fonctionne comme un charme sur ma machine Linux exécutant OpenSUse 11.3, mais un collègue le teste sur une machine très similaire en cours d'exécution Win7 obtient Notifications personnalisées des délais d'attente forts> sur l'interrogation de la file d'attente (voir le code ci-dessous), beaucoup d'entre eux réellement. J'ai essayé de surveiller l'utilisation du processeur sur sa machine, et il semble que le logiciel ne reçoit pas plus de 15% des CPU tandis que sur ma machine, l'utilisation du processeur frappe le toit, comme je l'ai voulu. P>

Ma question est que cela peut-il être un signe de "famine" de la file d'attente? Pourrait-il être pour que le fil du producteur ne reçoit pas assez de temps de processeur? Si oui, comment puis-je continuer à donner un fil particulier dans la priorité plus élevée de la piscine? P>

mise à jour: strong> J'essaie d'identifier le problème, sans joie ... je l'ai fait de nouvelles idées. p>

• Profilage de l'exécution du code avec Jvisalvm démontre un comportement très particulier. Les méthodes sont appelées dans des rafales courtes de la CPU-Time avec plusieurs secondes d'aucun progrès entre les deux. Cela signifie que l'OS est en quelque sorte frapper les freins sur le processus. P> Li>

• désactivation des démons anti-virus et de sauvegarde n'a aucun effet significatif sur la question p> li>

• Modification de la priorité de Java.exe (la seule instance) via Task Manager (Informé ici ) ne changent rien non plus. (Cela étant dit, je ne pouvais pas donner la priorité «en temps réel» à Java, et devait être satisfait de «Prio High») P> Li>

• Profilage de l'utilisation du réseau montre un bon déroulement de données dedans et je devine donc que ce n'est pas le goulot d'étranglement (alors qu'il s'agit d'une partie considérable du temps d'exécution du processus, mais que je connais déjà et est à peu près le même pourcentage que possible sur ma machine Linux). P> li> ul>

  Des idées sur la manière dont Win7 OS pourrait limiter le temps de la CPU à mon projet? Si ce n'est pas le système d'exploitation, quel pourrait être le facteur limitant? Je voudrais encore insister sur le fait que la machine n'exécute aucun autre calcul intensive en même temps et il n'ya presque aucune charge sur les CPU autres que mon logiciel. Cela me rend fou ... p>

  Modifier: Code correspondant strong> p>

  public ConcurrencyService(Dataset d, QueryService qserv, Set<MyObject> s){
  
      timeout = 3;
      this.qs = qserv;
      this.bq = qs.getQueue();
      this.ds = d;
      this.analyzedObjects = s;
      this.drc = DebugRoutineContainer.getInstance();
      this.started = false;
  
      int nbrOfProcs = Runtime.getRuntime().availableProcessors();
      poolSize = nbrOfProcs;
      pool = (ThreadPoolExecutor) Executors.newFixedThreadPool(poolSize);
      drc.setScoreLogStream(new PrintStream(qs.getScoreLogFile()));
  }
  
  public void serve() throws InterruptedException {
      try {
          this.ds.initDataset();
          this.started = true;
          pool.execute(new QueryingAction(qs));
          for(;;){
              MyObject p = bq.poll(timeout, TimeUnit.MINUTES);
  
              if(p != null){
                  if (p.getId().equals("0"))
                      break;
  
                  pool.submit(new AnalysisAction(ds, p, analyzedObjects, qs.getKnownAssocs()));
              }else 
                  drc.log("Timed out while waiting for an object...");
  
          }
  
        } catch (Exception ex) {
              ex.printStackTrace();
              String exit_msg = "Unexpected error in core analysis, terminating execution!";
  
        }finally{
              drc.log("--DEBUG: Termination criteria found, shutdown initiated..");
              drc.getMemoryInfo(true);    // dump meminfo to log
  
              pool.shutdown();
  
              int mins = 2;
              int nCores = poolSize;
              long    totalTasks = pool.getTaskCount(), 
                      compTasks = pool.getCompletedTaskCount(),
                      tasksRemaining = totalTasks - compTasks,
                      timeout = mins * tasksRemaining / nCores;
  
              drc.log("--DEBUG: Shutdown commenced, thread pool will terminate once all objects are processed, " +
                          "or will timeout in : " + timeout + " minutes... \n" + compTasks + " of " +  (totalTasks -1) + 
                          " objects have been analyzed so far, " + "mean process time is: " +
                          drc.getMeanProcTimeAsString() + " milliseconds.");
  
              pool.awaitTermination(timeout, TimeUnit.MINUTES);
        }
  
  }