一个简单的JAVA线程池(只是用实验)

短命女 2022-09-19 10:59 140阅读 0赞

![None.gif][] package  myTest\_EA;  
![None.gif][]  
![None.gif][] import  java.util. \* ;  
![None.gif][]  
![None.gif][] public   class  ThreadPool  extends  Thread  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] ... \{  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    /\*\* \*//\*\*  
![InBlock.gif][]     \* @param args  
![ExpandedSubBlockEnd.gif][]     \*/  
![InBlock.gif][]      
![InBlock.gif][]    //pool是作业数  
![InBlock.gif][]    private List pool;  
![InBlock.gif][]      
![InBlock.gif][]    public ThreadPool(List pool)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        this.pool = pool ;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]      
![InBlock.gif][]    public void run()  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        for(int i = 0; i < 3; i\++)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            synchronized(pool)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ...\{  
![InBlock.gif][]                while(pool.isEmpty())  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                ...\{  
![InBlock.gif][]                    try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                    ...\{  
![InBlock.gif][]                        System.out.println( " thread name:" \+ this.getName() \+ " pool.wait()");  
![InBlock.gif][]                        pool.wait();  
![ExpandedSubBlockEnd.gif][]                    \}  
![InBlock.gif][]                    catch(InterruptedException ex)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                    ...\{  
![InBlock.gif][]                          
![ExpandedSubBlockEnd.gif][]                    \}  
![ExpandedSubBlockEnd.gif][]                \}  
![InBlock.gif][]                pool.remove(pool.size() \- 1);  
![InBlock.gif][]                System.out.println(" pool.size()" \+ pool.size() \+ " thread name:" \+ this.getName());  
![InBlock.gif][]                  
![ExpandedSubBlockEnd.gif][]            \}  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]          
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]      
![InBlock.gif][]      
![InBlock.gif][]      
![InBlock.gif][]    public final static int THREAD\_COUNT = 5;  
![InBlock.gif][]      
![InBlock.gif][]    public static void main(String\[\] args)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]        // TODO Auto-generated method stub  
![InBlock.gif][]          
![InBlock.gif][]        Vector pool = new Vector();  
![InBlock.gif][]          
![InBlock.gif][]        ThreadPool\[\] threadPool = new ThreadPool\[THREAD\_COUNT\];  
![InBlock.gif][]          
![InBlock.gif][]        System.out.println("a");  
![InBlock.gif][]        System.out.println(threadPool.length);  
![InBlock.gif][]        for(int i = 0; i < threadPool.length; i\++)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            threadPool\[i\] = new ThreadPool(pool);  
![InBlock.gif][]            threadPool\[i\].start();  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]        System.out.println("b");  
![InBlock.gif][]        for(int i = 0; i < 10; i\++)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            synchronized(pool)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ...\{  
![InBlock.gif][]                System.out.println("" \+ i \+ "" );  
![InBlock.gif][]                pool.add(0,"bbbbbbbbbb");  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                /\*\*//\*pool.add(1,"ccc");  
![InBlock.gif][]                pool.add(2,"dd");  
![InBlock.gif][]                pool.add(3,"e");  
![ExpandedSubBlockEnd.gif][]                pool.add(4,"ee");\*/  
![InBlock.gif][]                //pool.add(5,"f");  
![InBlock.gif][]                pool.notifyAll();  
![InBlock.gif][]                System.out.println("pool.size:" \+ pool.size() );  
![InBlock.gif][]                System.out.println("threadPool:" \+ threadPool.length );  
![ExpandedSubBlockEnd.gif][]            \}  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]          
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        /\*\*//\*for(int i = 0; i < threadPool.length; i++)  
![InBlock.gif][]        \{  
![InBlock.gif][]            threadPool\[i\].interrupt();  
![ExpandedSubBlockEnd.gif][]        \}\*/  
![InBlock.gif][]          
![InBlock.gif][]          
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]      
![InBlock.gif][]      
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

当程序中还有线程处于wait()状态时,程序不会自动退出(未完待续,代码会帖上改进后的)

[None.gif]: /images/20220828/beb8e31c4b604d56ace3f52ebae7ab3f.png
[ExpandedBlockStart.gif]: http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedBlockStart.gif
[ContractedBlock.gif]: /images/20220828/688b8f241a9243d6bd75f8a4822a178d.png
[InBlock.gif]: /images/20220828/3a97d58a8ae24ac9986c7070c1aa0739.png
[ExpandedSubBlockStart.gif]: http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedSubBlockStart.gif
[ContractedSubBlock.gif]: /images/20220828/ef2bebd3c4d541b1bfcf4724c4438102.png
[ExpandedSubBlockEnd.gif]: /images/20220828/7ae710ad96534aa69497639b0aa8866d.png
[ExpandedBlockEnd.gif]: /images/20220828/5c780b7c8bb647e7afda37021d1340f7.png