зацикливания в Java для определенной продолжительности и определенной задачи

Question

У меня есть требование следующим

loop(N times) 
{ 
for(1 minute) 
{ 
write certain values to a tree map 
} 
for(exactly after that above 1 min task) 
{ 
serialize the tree map 
return the tree map 
create a new tree map 
} 
} 

Как я этого добиться?

Это то, что я сделал до сих пор ..

public class StoreMessage { 
    private static long start_nanotime=System.nanoTime(); 
    private static Thread thisThread = Thread.currentThread(); 
    private static int timeToRun = 60000; // 1 minute 
    private static byte[] b=null; 
    public static Map <Long,Message> map1=new TreeMap<Long,Message>(); 

    public static byte[] store(Message message){ 

     new Thread(new Runnable(){ 
      public void run(){ 
       try{ 
        sleep(timeToRun); 
        thisThread.interrupt(); 
        b=serializer.serialize(map1); 
        new TreeMap<Long,Message>(); 
       } catch(Exception e){ 
        e.printStackTrace(); 
       } 
       } 
     }).start(); 

     while (!Thread.interrupted()) { 
      long precise_time=TimeUnit.MILLISECONDS.toNanos(System.currentTimeMillis())+(System.nanoTime()-start_nanotime); 
      map1.put(precise_time, message); 
     } 
     return b; 
    } 
} 

Я пытался сохранить все объекты JMS из класса Message за полученный в одну минуту на карте дерева против его точного времени как key.After завершение одной минуты, я хочу сериализовать карту и вернуть байт [] в другой класс. Тем временем я создаю новую карту деревьев для хранения следующего набора сообщений JMS в течение минуты. Этот код является некоторым, как не работает. Это дает мне ошибку java.lang.OutOfMemoryError: Java heap space. Также я заметил, что он продолжает писать только одно сообщение на карту, то есть, если сообщения были «привет», «хороший день для вас» - это два сообщения jms; класс StoreMessage получает одно сообщение за раз. Сначала он получит «привет», и как только это сообщение будет обработано, оно будет получать следующее сообщение. Но я заметил, что в течение одной минуты, когда поток не прерывается, он записывает только первое сообщение на карту и дает ошибку. Как это исправить?

Answer 1

Так что я не совсем уверен, что вы пытаетесь выполнить в своем коде, но я думал, что по крайней мере дам отзывы.

Во-первых, вы работаете из памяти, потому что вы в призвании спина петли:

map1.put(precise_time, message); 

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

Далее, это очень странно, чтобы разветвить нить, чтобы вы могли interrupt() родительский поток в более позднее время. Вместо этого я бы сделал что-то вроде следующего, которое устанавливает значение stop-at-time-millis, а затем запускается до тех пор, пока не будет достигнуто время. Это полностью избавляет от Thread.

long runUntilMillis = System.currentTimeMillis() + timeToRunMillis; 
while (true) { 
    long now = System.currentTimeMillis(); 
    if (now >= runUntilMillis) { 
     break; 
    } 
    long precise_time = ... 
    map1.put(precise_time, message); 
} 
return serializer.serialize(map1); 

Некоторые другие мысли:

• Ваш precise_time расчет неверен. Вы не можете взять число миллисекунд с эпохи и добавить их в nano-second значение System. Вероятно, вы переполнили long, если я не ошибаюсь. Фактически, расчет наносекунды был бы отрицательным значением, поэтому я не уверен, что вы пытались сделать там. Я бы просто использовал start_nanotime - System.nanoTime().
• Вы не можете сделать b = serializer.serialize(map1); во внутреннем Thread. Это даже не компилируется, так как b должен был быть определен внутри потока или быть final.
• Я не совсем понял new TreeMap<Long,Message>(); во внутреннем Thread, который просто создал бы TreeMap, который был бы немедленно помечен как мусор, так как вы его не назначили кому-либо. Может быть, вы хотели использовать map1.clear()?
• Вы помещаете то же значение message в каждый элемент в TreeMap. Не уверен, что это то, что вы намеревались.

Answer 2

Чтобы решить эту проблему, вам нужно будет работать с типом даты.

Для улучшения типа даты вы можете использовать joda-time или простую арифметику.

new Date() - создать экземпляр даты на текущий момент.

Date date1 = new Date(); 
Thread.sleep(4000); //Do nothing for 4 sec 
Date date2 = new Date(); 

long timeDiffInMs = date2.getTime() - date1.getTime(); 

Значение timeDiffInMs должно быть менее менее 4 секунд.