java写的线程池

深藏阁楼爱情的钟 2022-09-19 10:58 154阅读 0赞

UtilProperties.java

![None.gif][] package  org.ofbiz.smsSend;  
![None.gif][]  
![None.gif][] import  java.io.File;  
![None.gif][] import  java.io.FileInputStream;  
![None.gif][] import  java.io.FileNotFoundException;  
![None.gif][] import  java.io.FileOutputStream;  
![None.gif][] import  java.io.IOException;  
![None.gif][] import  java.util.Properties;  
![None.gif][]  
![None.gif][] public   class  UtilProperties  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] ... \{  
![InBlock.gif][]    private String fileName = "config.properties";  
![InBlock.gif][]    private Properties prop;  
![InBlock.gif][]    private FileInputStream in;  
![InBlock.gif][]    private FileOutputStream out;  
![InBlock.gif][]      
![InBlock.gif][]    public UtilProperties(String filePath) throws IOException  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        this.fileName = filePath;  
![InBlock.gif][]        getFile();  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]      
![InBlock.gif][]    public UtilProperties()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            getFile();  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]        catch (IOException e)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            // TODO Auto-generated catch block  
![InBlock.gif][]            e.printStackTrace();  
![ExpandedSubBlockEnd.gif][]        \}  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]      
![InBlock.gif][]    private void getFile() throws IOException  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        File file = new File(this.fileName);  
![InBlock.gif][]        in = new FileInputStream(file);  
![InBlock.gif][]        prop = new Properties();  
![InBlock.gif][]        prop.load(in);  
![InBlock.gif][]        in.close();  
![InBlock.gif][]          
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]    public void list()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        prop.list(System.out);  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]      
![InBlock.gif][]    public String getValue(String itemName)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        return prop.getProperty(itemName);  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]    public void setValue(String itemName,String value)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        prop.setProperty(itemName, value);  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]    public void saveFile() throws IOException  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        File f = new File(this.fileName);  
![InBlock.gif][]        out = new FileOutputStream(f);  
![InBlock.gif][]        prop.store(out, "");  
![InBlock.gif][]        out.close();  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]    public void deleteValue(String value)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        prop.remove(value);  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]    public void changeFile(String filePath)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        this.fileName = filePath;  
![InBlock.gif][]        try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            getFile();  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]        catch (IOException e)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            // TODO Auto-generated catch block  
![InBlock.gif][]            e.printStackTrace();  
![ExpandedSubBlockEnd.gif][]        \}  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]      
![InBlock.gif][]    public static void main(String\[\] args) throws IOException  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        UtilProperties up = new UtilProperties();  
![InBlock.gif][]        up.list();  
![InBlock.gif][]        up.changeFile("config.properties");  
![InBlock.gif][]        up.list();  
![InBlock.gif][]        System.out.println("" \+ up.getValue("temSavePath"));  
![ExpandedSubBlockEnd.gif][]    \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

ThreadPool.java

![None.gif][] package  org.ofbiz.smsSend;  
![None.gif][]  
![None.gif][] import  java.util.ArrayList;  
![None.gif][] import  java.util.Iterator;  
![None.gif][] import  java.util.LinkedList;  
![None.gif][] import  java.util.Timer;  
![None.gif][]  
![None.gif][] public   class  ThreadPool  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] ... \{  
![InBlock.gif][]    private static final UtilProperties utilProp = new UtilProperties();  
![InBlock.gif][]  
![InBlock.gif][]    private static int minPools = Integer.parseInt(utilProp  
![InBlock.gif][]            .getValue("minPools"));  
![InBlock.gif][]  
![InBlock.gif][]    private static int maxPools = Integer.parseInt(utilProp  
![InBlock.gif][]            .getValue("maxPools"));  
![InBlock.gif][]  
![InBlock.gif][]    private static int checkThreadPeriod = Integer.parseInt(utilProp  
![InBlock.gif][]            .getValue("checkThreadPeriod")) \* 60 \* 1000;  
![InBlock.gif][]  
![InBlock.gif][]    private static ArrayList workThreadList; // 工作线程列表，保存所有的线程  
![InBlock.gif][]  
![InBlock.gif][]    private static LinkedList taskList = null; // 工作任务列表，保存将要执行的工作任务  
![InBlock.gif][]  
![InBlock.gif][]    private static int totalThread = 0; // 总线程数  
![InBlock.gif][]  
![InBlock.gif][]    private static int freeThreadCount = 0; // 未被使用的线程数目  
![InBlock.gif][]  
![InBlock.gif][]    private java.util.Timer timer = null; // 定时器  
![InBlock.gif][]  
![InBlock.gif][]    private static Object o = new Object();  
![InBlock.gif][]  
![InBlock.gif][]    private static ThreadPool pool = new ThreadPool();  
![InBlock.gif][]  
![InBlock.gif][]    public static void setMinPools(int minPools)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        ThreadPool.minPools = minPools;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]    public static void setMaxPools(int maxPools)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        ThreadPool.maxPools = maxPools;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]    public static void setCheckThreadPeriod(int checkThreadPeriod)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        ThreadPool.checkThreadPeriod = checkThreadPeriod;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]    private ThreadPool()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        workThreadList = new ArrayList();  
![InBlock.gif][]        taskList = new LinkedList();  
![InBlock.gif][]        // 初始化线程池  
![InBlock.gif][]        for (int i = 0; i < ThreadPool.minPools; i\++)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            WorkerThread temp = new WorkerThread();  
![InBlock.gif][]            totalThread = totalThread \+ 1;  
![InBlock.gif][]            workThreadList.add(temp);  
![InBlock.gif][]            temp.start();  
![InBlock.gif][]            try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ...\{  
![InBlock.gif][]                Thread.sleep(100);  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]            catch (Exception e)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ...\{  
![ExpandedSubBlockEnd.gif][]            \}  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]        timer = new Timer(true); // 启动定时器  
![InBlock.gif][]        timer.schedule(new CheckThreadTask(this), 0, checkThreadPeriod);  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]    public static ThreadPool getInstance()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        return pool;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]    public synchronized void run(Work work)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        if (freeThreadCount == 0)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            if (totalThread < maxPools)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ...\{  
![InBlock.gif][]                WorkerThread temp = new WorkerThread();  
![InBlock.gif][]                totalThread = totalThread \+ 1;  
![InBlock.gif][]                workThreadList.add(temp);  
![InBlock.gif][]                temp.start();  
![InBlock.gif][]                synchronized (taskList)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                ...\{  
![InBlock.gif][]                    taskList.add(work);  
![InBlock.gif][]                    taskList.notify();  
![ExpandedSubBlockEnd.gif][]                \}  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]            else  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ...\{  
![InBlock.gif][]                while (freeThreadCount == 0)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                ...\{  
![InBlock.gif][]                    try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                    ...\{  
![InBlock.gif][]                        Thread.sleep(200);  
![ExpandedSubBlockEnd.gif][]                    \}  
![InBlock.gif][]                    catch (InterruptedException e)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                    ...\{  
![ExpandedSubBlockEnd.gif][]                    \}  
![ExpandedSubBlockEnd.gif][]                \}  
![InBlock.gif][]                synchronized (taskList)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                ...\{  
![InBlock.gif][]                    taskList.add(work);  
![InBlock.gif][]                    taskList.notify();  
![ExpandedSubBlockEnd.gif][]                \}  
![ExpandedSubBlockEnd.gif][]            \}  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]        else  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            synchronized (taskList)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ...\{  
![InBlock.gif][]                taskList.add(work);  
![InBlock.gif][]                taskList.notify();  
![ExpandedSubBlockEnd.gif][]            \}  
![ExpandedSubBlockEnd.gif][]        \}  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    /\*\* \*//\*\* \*/  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    /\*\* \*//\*\*  
![InBlock.gif][]     \* 检查工作线程列表，将非活动状态的线程换成活动状态的线程，保证线程池中的线程可用 119 \* 120  
![ExpandedSubBlockEnd.gif][]     \*/  
![InBlock.gif][]    public synchronized void checkAllThreads()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]  
![InBlock.gif][]        Iterator threadIterator = workThreadList.iterator();  
![InBlock.gif][]  
![InBlock.gif][]        while (threadIterator.hasNext())  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{ // 逐个遍厉  
![InBlock.gif][]            WorkerThread workThread = (WorkerThread) threadIterator.next();  
![InBlock.gif][]  
![InBlock.gif][]            if (!(workThread.isAlive()))  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ...\{  
![InBlock.gif][]                // 如果处在非活动状态时  
![InBlock.gif][]                workThread = new WorkerThread(); // 重新生成1个线程  
![InBlock.gif][]                workThread.start(); // 启动  
![ExpandedSubBlockEnd.gif][]            \}  
![ExpandedSubBlockEnd.gif][]        \}  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]    public static void printInfo()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        System.out.println("minPools:" \+ minPools);  
![InBlock.gif][]        System.out.println("maxPools:" \+ maxPools);  
![InBlock.gif][]        System.out.println("checkThreadPeriod:" \+ checkThreadPeriod);  
![InBlock.gif][]        System.out.println("totalThread=" \+ totalThread);  
![InBlock.gif][]        System.out.println("workThreadList.size()=" \+ workThreadList.size());  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    /\*\* \*//\*\* \*/  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    /\*\* \*//\*\*  
![InBlock.gif][]     \* 149 \* 线程池中的工作线程类，由工作线程执行我们要进行的操作 150  
![ExpandedSubBlockEnd.gif][]     \*/  
![InBlock.gif][]    class WorkerThread extends Thread  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        boolean running = true;  
![InBlock.gif][]  
![InBlock.gif][]        Work work;  
![InBlock.gif][]  
![InBlock.gif][]        public void run()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            while (running)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ...\{  
![InBlock.gif][]                synchronized (o)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                ...\{  
![InBlock.gif][]                    freeThreadCount\++; // 一进来说明多了一个可用线程  
![ExpandedSubBlockEnd.gif][]                \}  
![InBlock.gif][]                synchronized (taskList)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                ...\{  
![InBlock.gif][]                    while (taskList.size() == 0) // 当工作任务列表为空时，等待  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                    ...\{  
![InBlock.gif][]                        try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                        ...\{  
![InBlock.gif][]                            taskList.wait();  
![InBlock.gif][]                            if (!running)  
![InBlock.gif][]                                return;  
![ExpandedSubBlockEnd.gif][]                        \}  
![InBlock.gif][]                        catch (InterruptedException e)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                        ...\{  
![ExpandedSubBlockEnd.gif][]                        \}  
![ExpandedSubBlockEnd.gif][]                    \}  
![InBlock.gif][]                    synchronized (o)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                    ...\{  
![InBlock.gif][]                        freeThreadCount\--; // 得到一个工作，可用线程要减1  
![ExpandedSubBlockEnd.gif][]                    \}  
![InBlock.gif][]                    work = (Work) taskList.removeLast(); // 从任务列表处获得一个任务  
![InBlock.gif][]                    if (work == null)  
![InBlock.gif][]                        return;  
![ExpandedSubBlockEnd.gif][]                \}  
![InBlock.gif][]                work.doWork();  
![ExpandedSubBlockEnd.gif][]            \}  
![ExpandedSubBlockEnd.gif][]        \}  
![ExpandedSubBlockEnd.gif][]    \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

CheckThreadTask.java

![None.gif][] package  org.ofbiz.smsSend;  
![None.gif][]  
![None.gif][] import  java.util. \* ;  
![None.gif][]  
![None.gif][] public   class  CheckThreadTask  extends  TimerTask  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] ... \{  
![InBlock.gif][]    private static boolean isRunning = false;  
![InBlock.gif][]    private ThreadPool pool;  
![InBlock.gif][]      
![InBlock.gif][]    public CheckThreadTask(ThreadPool pool)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        this.pool = pool;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]      
![InBlock.gif][]      
![InBlock.gif][]    @Override  
![InBlock.gif][]    public void run()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        // TODO Auto-generated method stub  
![InBlock.gif][]        if(!isRunning)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            isRunning = true;  
![InBlock.gif][]            pool.checkAllThreads();  
![InBlock.gif][]            isRunning = false;  
![ExpandedSubBlockEnd.gif][]        \}  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

Work.java

![None.gif][] package  org.ofbiz.smsSend;  
![None.gif][]  
![None.gif][] public   interface  Work  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] ... \{  
![InBlock.gif][]    public abstract void doWork();  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

Test.java

![None.gif][] package  org.ofbiz.smsSend;  
![None.gif][]  
![None.gif][] public   class  Test  implements  Work  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] ... \{  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    /\*\* \*//\*\*  
![InBlock.gif][]     \* @param args  
![ExpandedSubBlockEnd.gif][]     \*/  
![InBlock.gif][]    public static void main(String\[\] args)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        // TODO Auto-generated method stub  
![InBlock.gif][]        ThreadPool.getInstance().run(new Test());  
![InBlock.gif][]        ThreadPool.printInfo();  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]    public void doWork()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        // TODO Auto-generated method stub  
![InBlock.gif][]        System.out.println("a");  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

[None.gif]: /images/20220828/5cffe6d5f53b4966ab948e0db468d157.png
[ExpandedBlockStart.gif]: http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedBlockStart.gif
[ContractedBlock.gif]: /images/20220828/528236c817da4310bf39768b9363bfc5.png
[InBlock.gif]: /images/20220828/58a96ad18bc0465c866cb2d9812489ee.png
[ExpandedSubBlockStart.gif]: http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedSubBlockStart.gif
[ContractedSubBlock.gif]: /images/20220828/d9f53205405d40c19df7964543c16adb.png
[ExpandedSubBlockEnd.gif]: /images/20220828/96e36b1ab7374323bd58840933930486.png
[ExpandedBlockEnd.gif]: /images/20220828/9eddeaa88902452a855c75c20dbd2de3.png