packagemessage;importjava.util.Scanner;publicclassThread2{publicstaticvoidmain(String[]args){TextThread1t1=newTextThread1("线程1");TextThread2t2=newTextThread2("线程2");i...

package message;

import java.util.Scanner;

public class Thread2 {

public static void main(String[] args)

{

TextThread1 t1=new TextThread1("线程1");

TextThread2 t2=new TextThread2("线程2");

int x=10;

boolean iswait1=false;

boolean iswait2=false;

Scanner in=new Scanner(System.in);

x=in.nextInt();

while(x!=0)

{

switch(x)

{

case 1:

if(!t1.isAlive())

t1.start();

break;

case 2:

if(!t2.isAlive())

t2.start();

break;

case 3:

if(!iswait1)

{

synchronized(t1)

{

try

{

t1.wait();

}catch (InterruptedException e) {

e.printStackTrace();

}

}

iswait1=true;

}

break;

case 4:

if(!iswait2)

{

synchronized(t2)

{

try

{

t2.wait();

}catch (InterruptedException e) {

e.printStackTrace();

}

}

iswait2=false;

}

break;

case 5:

if(iswait1)

{

synchronized(t1)

{

t1.notify();

}

iswait1=false;

}

break;

case 6:

if(iswait2)

{

synchronized(t2)

{

t2.notify();

}

iswait2=false;

}

break;

case 7:

if(t1.isAlive())

{

try

{

Thread.sleep(1000);

}catch (InterruptedException e){}

t1.StopThread(true);

}

break;

case 8:

if(t2.isAlive())

{

try

{

Thread.sleep(1000);

}catch (InterruptedException e){}

t2.StopThread(true);

}

break;

default:

System.out.println("请重新输入");

break;

}

x=in.nextInt();

}

}

}

class TextThread1 extends Thread

{

private boolean isrun=true;

public TextThread1(String name)

{

super(name);

}

public void StopThread(boolean run)

{

this.isrun=!run;

}

public void run()

{

synchronized(this)

{

for(int i=0;i<1000000;i++)

{

if(!isrun)

break;

System.out.println(this.getName()+":"+i);

}

notify();

}

}

}

class TextThread2 extends Thread

{

private boolean isrun=true;

public TextThread2(String name)

{

super(name);

}

public void StopThread(boolean run)

{

this.isrun=!run;

}

public void run()

{

synchronized(this)

{

for(int i=1000000;i>0;i++)

{

if(!isrun)

break;

System.out.println(this.getName()+":"+i);

}

notify();

}

}

}

在线程1和2运行后，要执行3、4步的暂停线程，可是却没有反应。请大家看一看应该怎么改一下，如果还有其他地方不合适的话也请大家说一说，谢谢

展开