3

我有一项可以从线程池设计模式中受益的任务（许多小任务要并行执行）。我最初从头开始实现了一个简单的线程池，n 个 Runnables 都从同一个线程池中提取工作单元，ConcurrentLinkedQueue直到队列为空，然后终止。然后我决定“嘿，让我们试试 Java 中的 Executor，因为它可能比我天真的设计的系统测试得更好，更可靠。” 问题：在我的实现中，每个线程一直持续到队列为空，使用一段时间(!queue.isEmpty())，并获得了自己的非线程安全对象实例，我们称之为它SlowObject foo，构造起来很耗时。尝试将所有Runnable进入Executors 池的 s 传递给时间效率低的对象的实例失败，因为它不是线程安全的。SlowObject因为每个Runnable都是不可取的，因为它们的建造成本很高。

有没有办法说“我们正在使用多少个线程？让我们SlowObject为每个线程创建一个，然后让 Runnables 检测我们正在使用的线程并查找要使用的正确对象？” 这听起来很脆弱且容易失败——不过，我不确定我应该看什么设计模式。

4

2 回答 2

4

你最好使用资源池。使用这样的东西：

public class SlowObjectPool {
    private static final int POOL_SIZE = 10;
    private BlockingQueue<SlowObject> slowObjectQueue = new ArrayBlockingQueue(POOL_SIZE);

    public SlowObjectPool() {
        for (int i = 0; i < POOL_SIZE; i++) {
            slowObjectQueue.put(new SlowObject());
        }
    }

    public SlowObject take() throws InterruptedException {
        return slowObjectQueue.take();
    }

    public void release(SlowObject slowObject) {
        // TODO You may want to log a warning if this is false
        slowObjectQueue.offer(slowObject);
    }
}

您可能也希望将其设为单例。然后在您的可运行文件中：

public class MyRunnable implements Runnable {

    private SlowObjectPool pool;

    public MyRunnable(SlowObjectPool pool) {
        this.pool = pool;
    }

    @Override
    public void run() {
        // The next line blocks until a SlowObject is available
        SomeObject someObject = null;
        try {
            someObject = pool.take()
            // Do something with someObject
        } catch (InterruptedException ex) {
            // Thread is being ended, allow to end
        } finally {
            if (someObject != null)
                pool.release(someObject);
        }
    }
}

这将在首次创建池时立即创建所有对象，而不是动态创建它们，这样您的任何可运行对象都不必等待SomeObject创建实例。

于 2012-09-17T19:22:54.870 回答
3

Java 提供了ThreadLocal变量的概念。
您可以像这样在Runnable中使用它。

 public class MyJob implements Runnable {
     private static final ThreadLocal < SlowObject > threadLocal = 
       new ThreadLocal < SlowObject > () {
         @Override protected SlowObject initialValue() {
           // construct and return your SlowObject 
         }
       };

     public void run() {
       // work with threadLocal.get()
     }
   }

因此，对于运行 Runnable 的每个线程，只会创建一个 SlowObject 类的实例。

于 2012-09-17T19:13:55.530 回答