如何在Java中实现Active对象

在Java中实现Active对象模式，可以通过创建一个包含线程池的类来实现

1. 首先，创建一个实现Runnable接口的ActiveObject类：

public class ActiveObject implements Runnable {     private final BlockingQueue<Runnable> queue;      public ActiveObject() {         this.queue = new LinkedBlockingQueue<>();     }      @Override     public void run() {         while (true) {             try {                 Runnable task = queue.take();                 task.run();             } catch (InterruptedException e) {                 Thread.currentThread().interrupt();                 break;             }         }     }      public void addTask(Runnable task) {         try {             queue.put(task);         } catch (InterruptedException e) {             Thread.currentThread().interrupt();         }     } } 

2. 创建一个包含线程池的ActiveObjectManager类：

import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;  public class ActiveObjectManager {     private final ExecutorService executorService;      public ActiveObjectManager(int numberOfThreads) {         this.executorService = Executors.newFixedThreadPool(numberOfThreads);     }      public void submit(ActiveObject activeObject) {         executorService.submit(activeObject);     }      public void shutdown() {         executorService.shutdown();     } } 

3. 使用ActiveObject和ActiveObjectManager：

public class Main {     public static void main(String[] args) {         int numberOfThreads = 4;         ActiveObjectManager manager = new ActiveObjectManager(numberOfThreads);          ActiveObject activeObject1 = new ActiveObject();         ActiveObject activeObject2 = new ActiveObject();          manager.submit(activeObject1);         manager.submit(activeObject2);          activeObject1.addTask(() -> System.out.println("Task 1 executed by ActiveObject 1"));         activeObject1.addTask(() -> System.out.println("Task 2 executed by ActiveObject 1"));          activeObject2.addTask(() -> System.out.println("Task 1 executed by ActiveObject 2"));         activeObject2.addTask(() -> System.out.println("Task 2 executed by ActiveObject 2"));          manager.shutdown();     } } 

这个示例中，我们创建了两个ActiveObject实例，并将它们提交给ActiveObjectManager。然后，我们向这些ActiveObject实例添加任务，这些任务将由线程池中的线程执行。最后，我们关闭线程池。