Java多线程控制

Question

我正在使用这段代码来创建线程。

      while ((strLine = br.readLine()) != null) {
                r = new runnable(strLine);
                new Thread(r).start();
                x++;
                Thread.sleep(100);
      }

如何控制任意时刻运行的最大线程数？ 此代码存在内存使用不断上升（内存泄漏）的问题，有更好的方法吗？ 我尝试使用调度程序但没有帮助。

Answer 1

您可以使用 ExecutorService< /code>创建约束线程池。

ExecutorService executor = Executors.newFixedThreadPool(10);

将创建一个包含 10 个可用线程的池。然后您可以调用

executor.submit(new Runnable() { ... })

每个工作单元。

编辑：我应该注意，此功能仅在 Java 1.5 及更高版本中可用。