выполнить класс в своей собственной теме

Question

У меня есть класс InstanceFactory, который создает экземпляры определенного класса, назовем его классом instance. Эти экземпляры создаются в методе main(). В этом случае класс I в настоящее время звонит, как instance.init(), instance.put(), instance.stop().

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

Какие изменения я должен внести в класс экземпляра, чтобы позволить ему работать в отдельных потоках? Смогу ли я по-прежнему выполнять одни и те же вызовы, например. instance.init()?

Update (код добавляется):

InstanceFactory instanceFactory = new InstanceFactory(); 
try (Instance instance = instanceFactory.create()) { 
    instance.init(); 
    instance.doStuff(); 
    while ((input = reader.readNext()) != null) { 
     instance.put(input); 
    } 
} 

экземпляр должен работать в своем собственном потоке.

Answer 1

Вы могли бы, вероятно, использовать ExecutorService

Если instance.put() потокобезопасно, вы можете заменить Executors.newSingleThreadExecutor(); с Executors.newCachedThreadPool(), например.

InstanceFactory instanceFactory = new InstanceFactory(); 
ExecutorService executor = Executors.newSingleThreadExecutor(); 
try (Instance instance = instanceFactory.create()) { 
    instance.init(); 
    instance.doStuff(); 
    while ((input = reader.readNext()) != null) { 
     executor.execute(new Runnable() { 
      @Override 
      public void run() { 
       instance.put(input); 
      } 
     }); 
    } 
    executor.shutdown(); 
    executor.awaitTermination(1, TimeUnit.MINUTES); 
} 

Примечание: Это непроверенный код.

Answer 2

Executors.newSingleThreadExecutor() создает только один рабочего потока, так что вы будете иметь один основного потока + один рабочего потока с очередью в FIFO из post() задач. Если ваш метод post() равен thread-safety, вы должны использовать Executors.newCachedThreadPool(), который создает столько потоков при необходимости.

InstanceFactory instanceFactory = new InstanceFactory(); 
ExecutorService executor = Executors.newCachedThreadPool(); 
try (Instance instance = instanceFactory.create()) { 
    instance.init(); 
    instance.doStuff(); 
    while ((input = reader.readNext()) != null) { 
     executor.execute(new Runnable() { 
      @Override 
      public void run() { 
       instance.put(input); 
      } 
     }); 
    } 
} finally { 
    executor.shutdown(); 
} 

Я советую вам прочитать official documentation и некоторые guides о ExecutorService.