如何使用Java中的for循环使多个线程同时运行？

Question

我对 java 很陌生，并开始构建一个小程序来查找给定范围内的素数。 现在我尝试实现多任务处理，例如将要检查的数字分成n个部分，分别进行检查。我想让它尽可能灵活，所以我没有在代码中指定线程数，而是使用了一个提示变量。 现在，代码可以运行，但线程不能并行运行。

这里似乎有什么问题？

           [...]     
           System.out.println("How many Threads shall be used?");
           int b1 = scan.nextInt();
           scan.close();
           for (int i = 1; i <= b1; i++) {
             long u = (q/b1)*(i-1);
             long o = (q/b1)*i;
             System.out.println("Thread "+i+" started.");
             Thread t1 = new Thread(new thread1 (u, o, i));
             t1.start();
           }


class thread1 implements Runnable{
    public thread1 (long a, long b, int c) {
//a= min. number, b = max. number, c=number of Thread
        primefinder.findPrimes(b,a, c);
    }
    @Override
    public void run() {
        // TODO Auto-generated method stub
    }
}

Answer 1

来自 javadoc https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html：

class PrimeRun implements Runnable {
         long minPrime;
         PrimeRun(long minPrime) {
             this.minPrime = minPrime;
         }

         public void run() {
             // compute primes larger than minPrime
              . . .
         }
     }
    

您的逻辑必须在 run() 方法中。正是这个方法将被调用并在另一个线程上运行。 使用您的实际代码，您在 Runnable 的构造函数中进行计算，该构造函数在您的 for 循环中调用，因此是顺序的。

将您的计算转移到运行方法将解决问题。

编辑：如果您难以将参数传递给您的计算代码，您可以简化为：

Thread t1 = new Thread(() -> findPrimes(u, o, i));
t1.start();

它做同样的事情，在底层，它创建了一个匿名类来实现 Runnable 接口，该接口在类字段中捕获你的变量。

Answer 2

正如正确的Answer by Daniel 所说，您需要将业务逻辑移动到Runnable 的run 方法或Callable 的call 方法中以获取通过Future 返回的值.

此外，在现代 Java 中，我们很少直接处理 Thread 类。而是使用 Executors 框架。

ExecutorService es = Executors.newFixedThreadPool( x ) ;
for( … ) { es.submit( task ) ; }
es.shutdown() ;
es.awaitTermination( … ) ;

这已经在 Stack Overflow 上讨论过很多次了。所以搜索以了解更多信息。