VPF::Средство для обеспечения повторов

Zlatogorov

Дата 21.12.2007, 00:11 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 18.12.2007
Где: BW,Stuttgart

Репутация: нет
Всего: 1

А может не стоит так усложнять себе жизнь.
Для таймеров есть QUARZ .
Прописывается временной паттерн и создаётся scheduling, и всё, остальное он берёт на себя.
К примеру :
"0 0/5 14 * * ?" Fire every 5 minutes starting at 2pm and ending at 2:55pm, every day
Так что настройки очень гибкие. Сделал на нём Hotfolder - всё работает как часы.

LSD

Дата 21.12.2007, 12:27 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Т.е. я так понял основная проблема состоит в том, что анализатор при остановке должен дождаться пока выполняться все таски положенные в очередь executor-а?
Так?

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

sol78

Дата 21.12.2007, 20:12 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 366
Регистрация: 7.7.2007

Репутация: нет
Всего: 0

da, vernee poslednego i edinstvennogo (poka)

LSD

Дата 22.12.2007, 14:47 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Вот примерный код как реализовать CQueue

Код


import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;

public class TaskTest
{
  public static void main(String[] args) throws Exception
  {
    CQueue taskQueue = CQueue.getTaskQueue();
    taskQueue.startProcessing();
    for(int i = 0; i < 50; i++)
      taskQueue.addTask(new DelayTask((long) (Math.random() * 10000)));
    taskQueue.stopAndWait();
    System.out.println("Task queue stopped");
  }
}

class CQueue implements Runnable
{
  private static final int MAX_QUEUE_SIZE = 10;
  private static CQueue queue = null;
  private BlockingQueue<Runnable> tasksQueue;
  private ThreadPoolExecutor threadPool;
  private AtomicBoolean running = new AtomicBoolean(false);
  private Thread workingThread;

  private CQueue()
  {
  }

  public static CQueue getTaskQueue()
  {
    if(queue == null)
    {
      queue = new CQueue();
    }
    return queue;
  }

  public void addTask(Runnable task)
  {
    if(!running.get())
      throw new IllegalStateException("Processor is not running");
    try
    {
      tasksQueue.put(task);
    }
    catch(InterruptedException ex)
    {
      ex.printStackTrace();
    }
  }

  public void startProcessing()
  {
    if(workingThread != null && workingThread.isAlive())
      return;
    tasksQueue = new ArrayBlockingQueue<Runnable>(MAX_QUEUE_SIZE);
    threadPool = new ThreadPoolExecutor(10, 20, 10, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
    running.set(true);
    workingThread = new Thread(this, "CQueueWorkingThread");
    workingThread.start();
  }

  public void stopProcessing()
  {
    running.set(false);
  }

  public void join() throws InterruptedException
  {
    if(workingThread != null)
      workingThread.join();
  }

  public void stopAndWait() throws InterruptedException
  {
    stopProcessing();
    join();
  }

  public void run()
  {
    while(running.get() || !tasksQueue.isEmpty())
    {
      try
      {
        Runnable t = tasksQueue.poll(10, TimeUnit.MILLISECONDS);
        if(t != null)
        {
          System.out.println("Task " + t + " exec");
          threadPool.execute(t);
        }
      }
      catch(InterruptedException ex)
      {
      }
    }
    cleanup();
  }

  private void cleanup()
  {
    threadPool.shutdown();
    while(threadPool.getActiveCount() > 0)
    {
      try
      {
        Thread.sleep(10);
      }
      catch(InterruptedException e)
      {
      }
    }
    threadPool = null;
    tasksQueue = null;
    workingThread = null;
  }
}

class DelayTask implements Runnable
{
  private long timeout;

  public DelayTask(long timeout)
  {
    this.timeout = timeout;
  }

  public void run()
  {
    try
    {
      Thread.sleep(timeout);
    }
    catch(InterruptedException e)
    {
      e.printStackTrace();
    }
    System.out.println("DelayTask finished");
  }

  @Override
  public String toString()
  {
    return "DelayTask[" + timeout + "]";
  }
}

Там есть еще один момент, я не знаю что ты хотела реализовать на самом деле, но ограничение максимального размера tasksQueue на самом деле достаточно бесмысленно. Т.к. таски из нее в ThreadPoolExecutor перекидываются достаточно быстро и они никогда не заполняется.

--------------------

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »