Java 线程屈服/饥饿问题

Question

我正在编写一个将运行多线程银行的代码。我首先使用一个程序创建一组线程，然后将它们传递到另一个运行循环来启动它们的线程中。对于应用程序的一部分，我有一个 CPU 密集型方法，基本上在彼此之间运行一系列循环。唯一的问题是，由于某种原因，它没有按照我认为应该的方式产生。这是运行线程的代码：

public void run(){
    this.setPriority(MAX_PRIORITY);
    int count = 0;

    while(count<transactions.length){
        int copy = count;
            if(transactions[copy] instanceof Jumbler){
                System.out.println(copy + " is a jumbler.");
            }
            else{
                System.out.println(copy  + " is not a jumbler");
            }
        transactions[copy].run();
        count++;
    }

    }

然后是 Jumbler run 方法：

    public void run(){
    System.out.println("running jumbler");
    Thread.yield();
    Thread.currentThread().yield();
    try{
        Thread.currentThread().sleep(5000);
    }catch(InterruptedException e){}
    //this.setPriority(MIN_PRIORITY);
    System.out.println("still running.");
    Thread.yield();
    nums = new int[1000];
    int i = 0;

    do{
        Thread.yield();

        for(int x=0;x<1000;x++){
            Thread.yield();
            //System.out.println("in the loop");
            nums[x]=(int)(Math.random()*10000)+1;
            for(int y = 0;y<1000;y++){
                Thread.yield();
                //System.out.println("in the the loop");
                for(int z = 0;z<100;z++){
                    Thread.yield();
                }
            }
        }
        Thread.yield();
        i++;
        System.out.println(whichJumble + ": " + i);
    }while(i<1000);
}

所以，问题是我希望它屈服，允许 main 方法继续运行更多线程，但它会阻塞并等待 Jumbler 完成（这需要很长时间）。知道为什么会发生这种情况或如何解决它吗？

Answer 1

我认为问题出在主循环中的 transactions[copy].run(); 中。这个直接调用 run 方法，而不是在另一个系统线程中。而是使用 transactions[copy].start(); 启动线程。

Answer 2

看起来您正确地生成了线程（事实上，您根本没有生成它们）

如果您希望线程开始运行（与当前线程并发），您需要调用 start()< /code> 该 Thread 对象的方法，而您没有。

如果我正确理解您的代码，您希望第一个片段生成其他线程。因此，您应该将 transactions[copy].run() 更改为 transactions[copy].start()。

（这是一个有根据的猜测。如果您显示了 transaction 数组的定义，那就太好了。）

这是启动多个线程的典型方案：

class MyThread extends Thread {
  public void run() { 
    // Do something here ...
  }
}


// Prepare the array
MyThread[] arr = new MyThread[10];
for(int i = 0; i < arr.length; ++i)
  arr[i] = new MyThread();

...

// Launch the threads
for(int i = 0; i < arr.length; ++i)
  arr[i].start();

Answer 3

一旦线程运行，我认为不能保证调用 setPriority 时优先级会发生变化。

这两个语句做同样的事情：

Thread.yield();
Thread.currentThread().yield();

但是你可能不应该调用yield，让操作系统来做。