Попытка реализовать рабочий поток

Question

Мне нужно прочитать данные из таблицы и выполнить некоторую работу над каждой строкой и пометить строку как обновленную. Я не хочу снова читать обновленную строку. Вот что я планирую делать с ExecutorService. Это верно ?

Спасибо.

public class ScheduledDBPoll 
{ 
    public static void main(String args[]) 
    { 
     ExecutorService service = Executors.newFixedThreadPool(10); 
     /* Connect to database. */ 
     while (true) 
     { 
     /* Issue a select statment for un-updated rows. */ 
      /* Get the primary key. */ 

      service.submit(new Task(primaryKey));  /* Pass the primary key*/ 
      try 
      { 
       Thread.sleep(3000);  /* Sleep for 3 seconds. */ 
      } 
      catch (InterruptedException ex) 
      { 
       Logger.getLogger(ScheduledDBPoll.class.getName()).log(Level.SEVERE, null, ex); 
      } 
     } 
     /* Close the connection here. */ 
    } 
} 

final class Task implements Runnable 
{ 
    private int taskId; 

    public Task(int primayKey) 
    { 
     this.taskId = primayKey; 
    } 

    @Override 
    public void run() 
    { 
     try 
     { 
      /* Connect to database. */ 
      /* Select the passed primary key row. */ 
      /* Do some work, mark the row as updated. */ 
      /* Close the connection here. */    
     } 
     catch (InterruptedException ex) 
     { 
      Logger.getLogger(Task.class.getName()).log(Level.SEVERE, null, ex); 
     } 
    } 
} 

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

Answer 1

Во-первых, проблема терминологии, которая может быть важной: этот код не реализует «a» рабочий поток; он пытается одновременно выполнять одновременный доступ к базе данных до 10 потоков.

Так что если вы действительно сделали, на самом деле нужно только один рабочий поток, ваш фиксированный пул потоков должен быть размером 1, а не 10. Но тогда вам могут не понадобиться отдельные задачи, у вас может быть одна задача для всего и все становится проще.

Я не знаю, почему вы ждёте 3 секунды (на самом деле это одна секунда, несмотря на то, что говорит ваш комментарий), что кажется бессмысленным.

Кроме этого, кажется правильным.

Answer 2

Я бы использовал службу ScheduledExecutorService и не имел потока, который отправляет задание каждые три секунды. Я также поддерживал бы соединение открытым, поскольку создание соединения с базой данных происходит очень медленно.

Так что я бы реализовать это больше похоже

ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor(); 
service.scheduleAtFixedRate(new Task(), 1, 1, TimeUnit.SECONDS); 


final class Task implements Runnable { 
    private Connection connection; 
    private int taskId; 

    @Override 
    public void run() { 
     try { 
      if (!connectionIsOkay()) { 
       connectToDatabase(); 
       taskId = selectUnUpdatedRow(); 
      } 
      selectRowsToUpdate(); 
      processRowsToUpdate(); 
      markAsUpdated(); 

     } catch (Exception ex) { 
      Logger.getLogger(Task.class.getName()).log(Level.SEVERE, null, ex); 
     } 
    } 
    // TODO find a more elegant way to close the connection when finished. 
    public void finalise() { 
     closeConnection(); 
    } 
}