Блог

безопасна ли эта нить? Я продолжаю получать разные результаты каждый раз, когда не уверен, как сделать этот поток безопасным. Моя цель состоит в том, чтобы вычислить количество простых чисел, начиная с 5 -10000, но для этого используется поток для каждого вычисления. Я хотел бы отслеживать общее количество простых чисел. если я выполню приведенный ниже код, то иногда получу 21, а иногда 22.

 import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.io.IOException;

public class Main {
     private static AtomicInteger count =new AtomicInteger(0);
    private static ExecutorService ex = Executors.newFixedThreadPool(100);
   
     public static void main(String []args) throws IOException {
        int x =5;
        while(x < 90){
            final int index =x;
           ex.execute(new Runnable(){
                public void run(){
                    synchronized(count){
                        if(isPrime(index)){
                            count.incrementAndGet();
                        }
                    }
                }
            });
            x  ;
            //new Thread(task).start();
        }
        ex.shutdown();
        System.out.println(count.get()  "this how many numbers are  prime");
     }
     
    public static boolean isPrime(int n)
    {
        // Corner cases
        if (n <= 1)
            return false;
        if (n <= 3)
            return true;
 
        // This is checked so that we can skip
        // middle five numbers in below loop
        if (n % 2 == 0 || n % 3 == 0)
            return false;
 
        for (int i = 5; i * i <= n; i = i   6)
            if (n % i == 0 || n % (i   2) == 0)
                return false;
 
        return true;
    }
}
 

добавление функции shutdownAndAwaitTermination(ExecutorService ex) устранило проблему, а не просто вызов ex.shutdown(); , я позвонил shutdownAndAwaitTermination(ex);

  public static void shutdownAndAwaitTermination(ExecutorService ex) {
    ex.shutdown(); // Disable new tasks from being submitted
    try {
     // Wait a while for existing tasks to terminate
     if (!ex.awaitTermination(60, TimeUnit.SECONDS)) {
       ex.shutdownNow(); // Cancel currently executing tasks
       // Wait a while for tasks to respond to being cancelled
       if (!ex.awaitTermination(60, TimeUnit.SECONDS))
           System.err.println("Pool did not terminate");
     }
   } catch (InterruptedException ie) {
     // (Re-)Cancel if current thread also interrupted
     ex.shutdownNow();
     // Preserve interrupt status
     Thread.currentThread().interrupt();
   }
 }