1

3 つのスレッドを実行、中断、再開するプログラムを作成しようとしています。

コーディングは次のとおりです。

class Connectthread implements Runnable
{
public void run()
{
    for(int j=0;j<90;j+=10)
    System.out.println("Connecting..." + j + " Secs");
}
}

class DLoadthread implements Runnable
{
public void run()
{
    for(int d=0;d<60;d+=10)
    System.out.println("Downloading..." + d + " Secs");
}
}
class Runthread implements Runnable
{
public void run()
{
    for(int r=0;r<120;r+=10)
    System.out.println("Running..." + r + " Secs");
}
}
class EHAunitThread
{
Connectthread ct=new Connectthread();
DLoadthread dt=new DLoadthread();
Runthread rt=new Runthread();

public void main(String arg[])
{
    //putting threads into ready state.
    System.out.print("Starting threads\n");
    ct.start();
    dt.start();
    rt.start();

    System.out.print("Sleeping 3 seconds\n");
    safeSleep(3000, "Threads first sleep time interrupted\n");
    System.out.print("Suspending threads\n");
    ct.suspend();
    dt.suspend();
    rt.suspend();

    System.out.print("Sleep 5 seconds\n");
    safeSleep(5000, "Threads second sleep time interrupted\n");
    System.out.print("Resume threads\n");
    ct.resume();
    dt.resume();
    rt.resume();

    try
    {
        ct.join();
        dt.join();
        rt.join();
    }
    catch (InterruptedException e)
    {
        System.out.print("Join interrupted");
    }

    System.out.print("Testcase Completed");
    System.exit(0);
}
}

error:cannot find symbolコンパイルしようとすると、これらのメッセージが 14 個表示され続けます。

私の知る限り、文法に関する限り、コーディングは正しいように見えます。ここで何が間違っていますか？

4

3 に答える 3

2

あなたのクラスは Runnables であり、それらの Thread メソッドを呼び出します。それらを Thread オブジェクトでラップする必要があります。

Thread ct=new Thread (newConnectthread());

また、 Thread#suspend()は推奨されていないことにも注意してください。

于 2012-10-30T20:23:25.097 に答える
1

Suspend と resume() は安全ではありません。次のアプローチを試してください。

public class Pauser{

  private boolean isPaused=false;

  public synchronized void pause(){
     isPaused=true;
    }

  public synchronized void resume(){
    isPaused=false;
    notifyAll();
  }

  public synchronized void look(){
    while(isPaused){
        wait();
      }
   }

}

public class MyRunnable implements Runnable{

  Pauser pauser;

  public MyRunnable(Pauser pauser){
     this.pauser=pauser;
   }

  public void run(){
    while(true){
       pauser.look();
    }
  }

public class Caller{

  Pauser pauser=new Pauser();
  for(int i = 0; i<1000;i++)
    new Thread(new MyRunnable(pauser)).start();

//pause all threads
pauser.pause();

//resume all threads
pauser.resume();
}
于 2013-02-27T20:43:55.023 に答える
1

Runnable has no start method. You need to use the Thread class to encapsulate the Runnables:

Thread ct = new Thread(new Connectthread());
Thread dt = new Thread(new DLoadthread());
Thread rt = new Thread(new Runthread());
于 2012-10-30T20:23:58.903 に答える