начинающий | threadPool | распечатать каждый результат | неправильный результат

Question

Я попытался добавить 1 к «глобальному счетчику» по каждой теме. Таким образом, результат «глобального счетчика» должен быть равен 10. Я распечатываю каждый результат каждой нити. В большинстве случаев последним результатом является 10. но некоторое время 10 не является последним числом. Я использовал синхронизацию или блокировку, но не работал.

спасибо. Надеюсь, мой английский не так уж плох.

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

public class Hauptprogramm { 

public static final int MAX_THREADS = 10; 
public static int globalCounter; 

public static void main(String[] args) { 

// create a pool of threads, 10 max jobs will execute in parallel 
ExecutorService threadPool = Executors.newFixedThreadPool(MAX_THREADS); 

// submit jobs to be executing by the pool 
for (int i = 0; i < MAX_THREADS; i++) { 
    threadPool.submit(new Runnable() { 

    public void run() { 
     // some code to run in parallel 
     globalCounter++; 


     String originalName = Thread.currentThread().getName(); 
     System.out.println("Result: "+globalCounter+" "+originalName); 


     try { 
     Thread.sleep(1000); 

     } catch (InterruptedException e) { 

     } 

    } 
    }); 
} 
    threadPool.shutdown(); 
    } 
} 

Answer 1

я бродил, что было ожидать от этого теста, так как я не имею 50 репутации еще, я не могу добавлять комментарии.

Java-поток работает в JVM, где нет контроля над распределением ресурсов с высокого уровня, если у вас есть запрос на то, что поток запускает выполнение за другим, используйте механизм блокировки блокировки, но нет никакой гарантии, что он будет выполняться последовательно, если вы попросили сделать это последовательно, вам нужно сделать некоторую логику для распознавания того, какой поток требуется выполнять друг за другом.

Answer 2

я думаю, что это прямо сейчас:

  public void run() { 
       synchronized(Hauptprogramm.class) 
        { 


       globalCounter++; 

       String originalName = Thread.currentThread().getName(); 
       System.out.println("Result: " + globalCounter + " " + originalName); 

       try { 
        Thread.sleep(100); 

       } catch (InterruptedException e) { 

       } 

        } 
      }}); 
     } 

    threadPool.shutdown(); 
} 
}