多线程练习题

Posted 2022-01-02 nnnnmmmm

多线程练习题

编写程序实现,子线程循环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();