不断运行的线程

首先，我建议您调查并解决OutOfMemoryException，因为最好避免这些情况。您可以实例化一个等待请求的线程，执行一个请求，然后返回以等待另一个请求。线程的实现是这样的：

/** Squares integers. */
public class Squarer {

    private final BlockingQueue<Integer> in;
    private final BlockingQueue<SquareResult> out;

    public Squarer(BlockingQueue<Integer> requests,
                   BlockingQueue<SquareResult> replies) {
        this.in = requests;
        this.out = replies;
    }
    public void start() {
        new Thread(new Runnable() {
            public void run() {
                while (true) {
                    try {

                // block until a request arrives
                    int x = in.take();
                    // compute the answer and send it back
                    int y = x * x;
                    out.put(new SquareResult(x, y));
                } catch (InterruptedException ie) {
                    ie.printStackTrace();
                }
            }
        }
    }).start();
}

} 对于调用者方法：

public static void main(String[] args) {

    BlockingQueue<Integer> requests = new LinkedBlockingQueue<>();
    BlockingQueue<SquareResult> replies = new LinkedBlockingQueue<>();

    Squarer squarer = new Squarer(requests, replies);
    squarer.start();

    try {
        // make a request
        requests.put(42);
        // ... maybe do something concurrently ...
        // read the reply
        System.out.println(replies.take());
    } catch (InterruptedException ie) {
        ie.printStackTrace();
    }
}

有关更多信息，您可以开始阅读我在此处找到的示例，以向您提供示例。