标签：class   练习   hash   UNC   tran   catch   mat   习题   span   

多线程练习题

编写程序实现,子线程循环3次,接着主线程循环5次,接着再子线程循环3次,主线程循环5次,如此反复,循环3次

第一种实现方式：使用synchronized关键字

?
package com.aaa.test;
?
public class Test1 {
?
    private boolean flag=false;
?
//    主线程要实现的功能
    public synchronized void mainFunction(){
?
        while (!flag){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        for (int i=0;i<5;i++){
            System.out.println("mainFunction,主线程循环"+i+"次");
        }
        this.notify();
        flag=false;
    }
?
//    子线程要实现的功能
    public synchronized void subFunction(){
?
        while (flag){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        for (int i=0;i<3;i++){
            System.out.println("subFunction,子线程循环"+i+"次");
        }
        this.notify();
        flag=true;
    }
?
    public static void main(String[] args) {
       final Test1 t= new Test1();
//       子线程循环三次
        new Thread(new Runnable() {
?
            public void run() {
                for (int i=0;i<3;i++){
                    t.subFunction();
                    System.out.println("======");
                }
            }
        }).start();
?
//        主线程循环三次
        for (int i=0;i<3;i++){
            t.mainFunction();
            System.out.println("======");
        }
    }
}
?
?

第二种实现方式：使用 lock 锁和 Condition 接口

?
package com.aaa.test;
?
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
?
public class Test2 {
    private boolean flag = false;
    Lock lock = new ReentrantLock();
    Condition con = lock.newCondition();
?
//    主线程要实现的功能
    public void mainFunction(){
        System.out.println("1.主线程开始"+" -- flag="+flag);
        lock.lock();
        try{
            while(!flag){
                try {
                    System.out.println("2.主线程等待"+" -- flag="+flag);
                    con.await();
                    // 使当前线程加入 await() 等待队列中，并释放当锁，当其他线程调用signal()会重新请求锁。与Object.wait()类似。
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("7.主线程开始循环5次"+" -- flag="+flag);
            for(int i=0;i<5;i++){
                System.out.println("mainFunction"+i+" -- flag="+flag);
            }
            flag = false;
            System.out.println("8.唤醒子线程"+" -- flag="+flag);
            con.signal();
            // 唤醒一个在 await()等待队列中的线程。与Object.notify()相似
        }finally{
            lock.unlock();
        }
    }
?
    // 子线程要实现的功能
    public void subFunction(){
        System.out.println("3.子线程开始"+" -- flag="+flag);
        lock.lock();
        try{
            while(flag){
                try {
                    System.out.println("6.子线程等待"+" -- flag="+flag);
                    con.await();  // 使当前线程加入 await() 等待队列中，并释放当锁，当其他线程调用signal()会重新请求锁。与Object.wait()类似。
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("4.子线程开始循环3次"+" -- flag="+flag);
            for(int i=0;i<3;i++){
                System.out.println("subFunction"+i+" -- flag="+flag);
            }
            flag = true;
            System.out.println("5.唤醒主线程"+" -- flag="+flag);
            con.signal(); // 唤醒一个在 await()等待队列中的线程。与Object.notify()相似
        }finally{
            lock.unlock();
        }
    }
?
    public static void main(String[] args) {
        final Test2 t= new Test2();
//       子线程循环三次
        new Thread(new Runnable() {
?
            public void run() {
                for (int i=0;i<3;i++){
                    t.subFunction();
                    System.out.println("======");
                }
            }
        }).start();
?
//        主线程循环三次
        for (int i=0;i<3;i++){
            t.mainFunction();
            System.out.println("======");
        }
    }
}

模拟多个人通过一个山洞的模拟，这个山洞每次只能通过一个人，每个人通过山洞的时间为5秒，随机生成10个人，同时准备过此山洞，显示以下每次通过山洞的人的姓名。

package com.aaa.test;
?
import java.util.LinkedHashSet;
import java.util.Set;
?
public class Test3 implements Runnable{
    private static int deng=0;
    @Override
    public void run() {
        deng= deng+50;
?
        try
        {
            Thread.sleep(deng);
?
        } catch (InterruptedException e)
        {
?
            e.printStackTrace();
        }
?
        System.out.println(Thread.currentThread().getName()
                +" 过山洞");
    }
?
    public static void main(String[] args) {
        String ary[] ={"赵","钱","孙","李","周","吴","郑","王","冯","陈"};
?
        Test3 gsd = new Test3();
?
        Set<Integer> set=new LinkedHashSet<Integer>();
        while(true){
            if(set.size() == 10){
                break;
            }
?
            //乱序排列（随机）
            int a=(int) (Math.random()*10);
?
            set.add(a);
        }
        for(int b:set){
?
            Thread th = new Thread(gsd, ary[b]);
?
?
            th.start();
        }
    }
}

多线程练习题

标签：class   练习   hash   UNC   tran   catch   mat   习题   span   

原文地址：https://www.cnblogs.com/nnnnmmmm/p/10998722.html