Повышение эффективности для каждого потока, используя различные уникальный идентификатор

Question

Постановка задачи: -

Каждый поток использует уникальный идентификатор в диапазоне от 1 до 1000 и программа должна работать в течение 60 минут или больше, так что в 60 минут, возможно, что все идентификаторы будут закончены, поэтому мне нужно снова использовать эти ID,

Я знаю несколько способов сделать это, одним из способов является то, что я написал, обратившись за помощью из StackOverflow, но когда я попытался запустить это, я обнаружил, что после нескольких минут работы эта программа становится очень медленной и для распечатки идентификатора на консоли требуется много времени. А также иногда получаю ошибку OutOfMemory. Есть ли лучший способ решить эту проблему?

class IdPool { 
    private final LinkedList<Integer> availableExistingIds = new LinkedList<Integer>(); 

    public IdPool() { 
     for (int i = 1; i <= 1000; i++) { 
      availableExistingIds.add(i); 
     } 
    } 

    public synchronized Integer getExistingId() { 
     return availableExistingIds.removeFirst(); 
    } 

    public synchronized void releaseExistingId(Integer id) { 
     availableExistingIds.add(id); 
    } 
} 


class ThreadNewTask implements Runnable { 
    private IdPool idPool; 

    public ThreadNewTask(IdPool idPool) { 
     this.idPool = idPool; 
    } 

    public void run() { 
     Integer id = idPool.getExistingId(); 
     someMethod(id); 
     idPool.releaseExistingId(id); 
    } 

    private void someMethod(Integer id) { 
     System.out.println("Task: " +id); 
    } 
} 

public class TestingPool { 
    public static void main(String[] args) throws InterruptedException { 
     int size = 10; 
     int durationOfRun = 60; 
     IdPool idPool = new IdPool(); 
     // create thread pool with given size 
     // create thread pool with given size 
    ExecutorService service = new ThreadPoolExecutor(size, size, 500L, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(10), new ThreadPoolExecutor.CallerRunsPolicy()); 


     // queue some tasks 
     long startTime = System.currentTimeMillis(); 
     long endTime = startTime + (durationOfRun * 60 * 1000L); 

     // Running it for 60 minutes 
     while(System.currentTimeMillis() <= endTime) { 
      service.submit(new ThreadNewTask(idPool)); 
     } 

     // wait for termination   
     service.shutdown(); 
     service.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS); 
    } 
} 

Answer 1

Я уже объяснил вам в предыдущем вопросе, что ваш код, представленные миллионы и миллионы задач исполнителя, поскольку она представляет задачи в цикле в течение 60 минут, withot ждет.

Очень непонятно, какова конечная цель, но как вы, вы заполняете очередь задач, пока у вас больше нет памяти. Поскольку вы не объясняете цель своей программы, трудно дать вам какое-либо решение.

Но первое, что вы могли бы сделать, это ограничить размер очереди задач вашего исполнителя. Это заставит основной поток блокироваться каждый раз, когда очередь заполнена.