迷你项目练习题5模拟线程池

妖狐艹你老母 2021-09-25 07:02 211阅读 0赞

### 文章目录 ###

*  执行线程ExecuteThread类
 *  线程调度ThreadPoolExecutor类
 *  测试类Test

# 执行线程ExecuteThread类 #

/** * 执行线程 */
    public class ExecuteThread extends Thread { 
        //任务运行状态
        boolean runningFlag = false;
        //任务，代表回调
        private Runnable callBack;
        //构造方法
        public void setCallBack(Runnable callBack) { 
            this.callBack = callBack;
        }
    
        public synchronized void setRunningFlag(boolean runningFlag) { 
            this.runningFlag = runningFlag;
            if (runningFlag) { 
                this.notify();
            }
        }
    
        //重写run方法
        @Override
        public synchronized void run() { 
                while (true) { 
                    while (!runningFlag) { 
                        //非运行状态，也就是没有任务运行的状态
                        try { 
                            this.wait();
                        } catch (InterruptedException e) { 
                            e.printStackTrace();
                        }
                    }
                    //有任务则运行任务
                    callBack.run();
                    //运行完任务设置运行标志为false
                    setRunningFlag(false);
                }
            }
        }

# 线程调度ThreadPoolExecutor类 #

*  用来管理线程池，进行线程的调度

import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    
    /** * 线程池的调度器 * 用来管理线程池，进行线程的调度 */
    public class ThreadPoolExecutor { 
        //线程池
        List<ExecuteThread> threads;
        //线程池的初始化
        public ThreadPoolExecutor(int n) { 
            //同步管理池中的线程
            threads = Collections.synchronizedList(new ArrayList<>());
            for (int i = 0; i < n; i++) { 
                //创建线程
                ExecuteThread executeThread = new ExecuteThread();
                //将创建好的线程放入池中
                threads.add(executeThread);
                //启动线程
                executeThread.start();
            }
        }
    
        //执行任务的方法
        public void execute(Runnable callBack) { 
            //到线程池中找空闲的线程
            int i = 0;
            while (true) { 
                for (; i < threads.size(); i++) { 
                    //得到每一个线程
                    ExecuteThread executeThread = threads.get(i);
                    //判断每一个线程是否是运行的状态(忙状态)
                    //如果状态为空闲状态，可以使用它执行任务
                    if (!executeThread.runningFlag) { 
                        //设置要运行的任务
                        executeThread.setCallBack(callBack);
                        //设置状态为运行状态
                        executeThread.setRunningFlag(true);
                        //退出本次循环
                        break;
                    }
    
                }
                //没有找到空闲的线程
                if (i == threads.size()) { 
                    //提示没有资源，请稍后再访问
                    System.out.println("没有资源，请稍后再访问");
                }
                //找到后退出方法
                else { 
                    System.out.println("我在停止");
                    return;
                }
            }
        }
    }

# 测试类Test #

public class PoolTest { 
        public static void main(String[] args) { 
            //创建有5个线程的线程池
            ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5);
            //执行任务
            for (int i = 0; i < 5; i++) { 
                int finalI = i;
                try { 
                    Thread.sleep(1000);
                } catch (InterruptedException e) { 
                    e.printStackTrace();
                }
                threadPoolExecutor.execute(() -> System.out.println("任务"+ finalI));
            }
            System.exit(0);
    
        }
    }