Java线程产生/饥饿问题

我正在编写一个将运行多线程库的代码。我首先用一个程序创建一个线程数组，然后将它们传递给另一个运行循环来启动它们的线程。对于应用程序的一部分，我有一个CPU密集型方法，基本上在一个循环内运行一系列循环。唯一的问题是，由于某种原因，它不会产生我认为应该的方式。这里是正在运行的线程的代码：Java线程产生/饥饿问题

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); 
}

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

来源

2011-04-30 Ian

yield方法不能保证线程实际上会产生CPU，你最好使用1毫秒的休眠，或者创建优先级较低的线程。 – 2011-04-30 19:51:30

-1

一旦线程运行，我不认为你可以保证当你调用setPriority时优先级改变。

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

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

，但你可能不应该叫屈服，让操作系统做到这一点。

来源

2011-04-30 19:47:36 MeBigFatGuy

看来你是正确产卵线程（其实，你不产卵他们在所有）

如果你想有一个线程开始运行（同时当前线程），你需要调用该Thread对象的start()方法，您不知道。

如果我正确理解你的代码，你想要第一个片段产生其他线程。因此，您应该将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();

来源

2011-04-30 19:48:36

我想这个问题来在您的主循环中使用transactions[copy].run();。这个直接调用run方法，但不能在另一个系统线程中调用。请改用transactions[copy].start();开始线程。

来源

2011-04-30 19:49:29 Howard

Java线程产生/饥饿问题

回答

相关问题