学步园

实验目的

(1) 掌握多线程的概念与基本操作方法

(2) 掌握线程的并发控制技术

(3) 掌握线程同步技术

实验内容及要求

一、 编写程序创建5个线程，分别显示5个不同的字符串。分别用继承Thread类以及实现Runnable接口的两种方式实现。

 

 

 

   /**
 *
 * @author FREESKYC
*/
public class NewClass {
    public static void main(String args[]) throws Exception {
        int i = 0;
        Hello t = new Hello();
        Hello t1 = new Hello();
        Hello t2 = new Hello();
        Hello t3 = new Hello();
        Hello t4 = new Hello();
        t1.start();
        t2.start();
        t3.start();
        t4.start();
        t.start();
    }
}
class Hello extends Thread {
    int i;
    public void run() {
        while (true) {
            System.out.println("Hello" + i++);
            if (i == 5) {
                break;
            }
        }
    }
}
/**
 *
 * @author FREESKYC
*/
public class NewClass {
    public static void main(String args[]) throws Exception {
        int i = 0;
        Hello h1 = new Hello("idgjadkgk");
        Thread t1 = new Thread(h1);
        t1.start();
        Hello h2 = new Hello("dpgkaldl");
        Thread t2 = new Thread(h2);
        t2.start();
        Hello h3 = new Hello("oglrlel");
        Thread t3 = new Thread(h3);
        t3.start();
        Hello h4 = new Hello("iddk");
        Thread t4 = new Thread(h4);
        t4.start();
        Hello h = new Hello("ddddd");
        Thread t = new Thread(h);
        t.start();
    }
}
class Hello implements Runnable {
    String i = "";
    Hello(String str) {
        this.i = str;
    }
    public void run() {
        System.out.println(i);
    }
}

 

 

 

 

二、编写生产者/消费者模式的程序。生产者每隔100ms产生一个0~9之间的一个数，保存在一个MyNumber类型的对象中，并显示出来。只要这个MyNumber对象中保存了新的数字，消费者就将其取出来显示。试定义MyNumber类，编写消费者、生产者程序，并编写主程序创建一个MyNumber对象，一个生产者线程、一个消费者线程并将这两个线程启动。

 

   /**
 *
 * @author FREESKYC
*/
public class NewClass {

public static void main(String[] args) {
        MyNumber myber = new MyNumber();
        produ t1 = new produ(myber);
        consu t2 = new consu(myber);
        Thread th1 = new Thread(t1);
        Thread th2 = new Thread(t2);
        th1.start();
        th2.start();
    }
}

class produ implements Runnable {

    MyNumber num;

    produ(MyNumber ber) {
this.num = ber;
    }

public void run() {
for (int i = 0; i <= 10; i++) {
synchronized (num) {
if (num.str) {
int x = (int) (Math.random() * 9);
                    System.out.print("produ：");
                    num.setnumber(x);
try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    num.str = false;
                    num.notify();
                } else {
try {
                        num.wait();
                    } catch (InterruptedException e1) {
                        e1.printStackTrace();
                    }
                }
if (i == 10) {
                    System.exit(0);
                }
            }
        }

    }
}

class consu implements Runnable {

    MyNumber num;

    consu(MyNumber myber) {
this.num = myber;
    }

    @Override
public void run() {
for (int i = 0; i <= 10; i++) {
synchronized (num) {
if (!num.str) {
                    System.out.print("consu：");
                    System.out.println(num.getnumber());
                    num.str = true;
                    num.notify();
                } else {
try {
                        num.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
if (i == 10) {
                System.exit(0);
            }
        }
    }
}

class MyNumber {

int number;
boolean str = true;

public void setnumber(int number) {
this.number = number;
        System.out.println(number);
    }

public int getnumber() {
return number;
    }
}