Java 多线程练习

1.编写一个多线程的处理程序，其他线程运行10s后，使用main方法中断其他线程

package 多线程基础;
/*
* 编写一个多线程的处理程序，其他线程运行10s后，使用main方法中断其他线程
*/
class EXThreads implements Runnable
{
public void run()
{
try {
System.out.println("在run中休眠10s");
Thread.sleep(10000);
System.out.println("休眠结束!");
} catch (InterruptedException e) {
System.out.println("在run中被打断");
return;
}
System.out.println("在run中继续运行");
}
}
public class EX22_1 {

public static void main(String[] args) {
EXThreads t=new EXThreads();
Thread tt=new Thread(t);
tt.start();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("在main中结束其他线程!");
//tt.interrupt();
System.out.println("在main中退出!");
}

}


输出：
在run中休眠10s

在main中结束其他线程!

在main中退出!

休眠结束!

在run中继续运行

2.写一个生产电脑和搬运电脑的程序。要求生产出一台电脑就搬走一台电脑。如果新的电脑没有生产出来，则搬运工就要等待；如果生产出的电脑没有搬走，则要等待电脑搬走后再生产。在main方法中结束其他线程，然后输生产和搬运的电脑数量。

package 多线程基础;

class Computer
{
public int getCreat() {
return creat;
}
public void setCreat(int creat) {
this.creat = creat;
}

public int getGet() {
return get;
}

private boolean flag=false; //flag=false时可以生产电脑,flag=true时可以取走电脑
private int creat=0; //生产的电脑台数
private int get=0; //取走的电脑台数
public synchronized void creat() //生产电脑
{
if(flag) //flag=false时可以生产电脑
{
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
creat++; //生产的电脑数量加1
System.out.println("生产的第"+creat+"台电脑");
flag=true; //生产完一台电脑设置将flag设置为true
notify(); //唤醒Consumer线程取走电脑
}
public synchronized void get()
{
if(!flag) //flag=true时可以取走电脑
{
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
get++; //取走的电脑数量加1
System.out.println("取走的第"+get+"台电脑");
flag=false; //取走一台电脑设置将flag设置为false
notify(); //唤醒Product线程生产电脑
}
}

class Product implements Runnable
{
Computer com=null;
public Product(Computer com)
{
this.com=com;
}
boolean flag=true;
public void stopCreat()
{
flag=false;
}
public void run()
{
while(flag) //flag为false时停止生产电脑
{
com.creat();
}
}
}

class Comsumer implements Runnable
{
Computer com=null;
public Comsumer(Computer com)
{
this.com=com;
}
boolean flag=true;
public void stopGet()
{
flag=false;
}
public void run()
{
while(flag) //flag为false时停止取走电脑
{
com.get();
}
}
}

public class EX22_2 {

public static void main(String[] args) {
Computer com=new Computer();
Product product =new Product(com);
Comsumer comsumer =new Comsumer(com);
new Thread(product).start();
new Thread(comsumer).start();
try {
Thread.sleep(1); //主线程书面1毫秒
product.stopCreat(); //停止生产电脑
comsumer.stopGet(); //停止拿走电脑
} catch (InterruptedException e) {
e.printStackTrace();
}

System.out.println("一共生产了"+com.getCreat()+"台电脑");
System.out.println("一共取走了"+com.getGet()+"台电脑");
}

}


输出：
生产的第1台电脑

取走的第1台电脑

生产的第2台电脑

取走的第2台电脑

生产的第3台电脑

取走的第3台电脑

生产的第4台电脑

取走的第4台电脑

一共生产了4台电脑

一共取走了4台电脑

生产的第5台电脑