Java语言学习二十五（线程池）

落日映苍穹つ 2023-07-20 13:59 14阅读 0赞

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 4]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 5]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 6]

package com.gf.erp.thread;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    
    public class ThreadPoolTest { 
        public static void main(String[] args) throws Exception
        { 
        	//创建固定数量线程池
            ExecutorService executor = Executors.newFixedThreadPool(5);
            //模拟提交10个任务
            for (int i = 0; i < 10; i++) { 
                executor.submit(() -> { 
                    System.out.println("线程ID: " + Thread.currentThread().getId());
                    try { 
                    	//线程池中的线程等待1 
                        Thread.sleep(1000L);
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                });
            }
            executor.shutdown();
            System.out.println("最后执行打印...");
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 7]

package com.gf.erp.thread;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    
    public class ThreadPoolTest { 
        public static void main(String[] args) throws Exception
        { 
        	//创建固定数量线程池
            ExecutorService executor = Executors.newFixedThreadPool(5);
            //模拟提交10个任务
            for (int i = 0; i < 10; i++) { 
                Future f = executor.submit(() -> { 
                    System.out.println("线程ID: " + Thread.currentThread().getId());
                    try { 
                    	//线程池中的线程等待1 
                        Thread.sleep(1000L);
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                });
                f.get();
            }
            executor.shutdown();
            System.out.println("最后执行打印...");
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 8]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 9]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 10]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 11]  
使用Excutors线程池工厂提供的线程池实现

```csharp
    package com.gf.erp.thread;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    
    public class MyThreadPool2 { 
    	public static void bubbleSort(int[] dim)
    	{ 
    		for(int i=0;i<dim.length;i++)
    		{ 
    			for(int j=0;j<dim.length-1-i;j++)
    			{ 
    				if(dim[j]>dim[j+1])
    				{ 
    					int temp = dim[j];
    					dim[j] = dim[j+1];
    					dim[j+1] = temp;
    				}
    			}
    		}
    	}
    	
    	public static void main(String[] args) throws Exception
    	{ 
    		int[][] tasks = { 
    				{ 123,23,22,34,56,3,2,6,7,1,2,4,7,8,5,12,323},
    				{ 5,6,45,34,34,23,22,224,12,567,678,999,66,99},
    				{ 12,30,43,63,68,6,9,67,7,689,99,4,3,5,8,9,0},
    				{ 1,4,6,7,8,5,5,6,8,0,33,22,34,11,21,45,550,4},
    				{ 12,13,5,6,7,8,9,0,45,66,77,4,9,7,8,7,6,99,8},
    				{ 3,5,7,9,0,10,13,7,8,0,55,44,3,68,22,44,67,8}
    		};
    		for(int i=0;i<tasks.length;i++)
    		{ 
    			System.out.print("排序前数组:"+i+"=");
    			for(int j=0;j<tasks[i].length;j++)
    				System.out.print(tasks[i][j]+",");
    			System.out.println();
    		}
    		
            ExecutorService executor = Executors.newFixedThreadPool(5);
            for (int i = 0; i < tasks.length; i++) { 
            	int[] tempDim = tasks[i];
                Future f = executor.submit(() -> { 
                    System.out.println("thread id is: " + Thread.currentThread().getId());
                    try { 
                        Thread.sleep(1000L);
                        bubbleSort(tempDim);
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                });
                System.out.println(f.get());
            }
            executor.shutdown();
            System.out.println("--------------here");
            
    		for(int i=0;i<tasks.length;i++)
    		{ 
    			System.out.print("排序后数组:"+i+"=");
    			for(int j=0;j<tasks[i].length;j++)
    				System.out.print(tasks[i][j]+",");
    			System.out.println();
    		}
    	}
    }

使用自定义线程池实现
    
    ```csharp
    package com.gf.erp.thread;
    
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionHandler;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    
    
    public class MyThreadPool {
    	private int corePoolSize;
    	private int maximumPoolSize;
    	private long keepAliveTime;
    	private TimeUnit unit;
    	BlockingQueue<Runnable> workQueue;
    	ThreadFactory threadFactory;
    	RejectedExecutionHandler handler;
    
    	public static void bobbleSort(int[] dim)
    	{
    		for(int i=0;i<dim.length;i++)
    		{
    			for(int j=0;j<dim.length-1-i;j++)
    			{
    				if(dim[j]>dim[j+1])
    				{
    					int temp = dim[j+1];
    					dim[j+1] = dim[j];
    					dim[j] = temp;
    				}
    			}
    		}
    	}	
    
    	public MyThreadPool(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,
    			BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,
    			RejectedExecutionHandler handler,int[][] task)
    	{
    		ExecutorService es = new ThreadPoolExecutor(corePoolSize,maximumPoolSize,keepAliveTime,
    	            unit,workQueue,threadFactory,handler);
    		try
    		{
    			for(int i=0;i<task.length;i++)
    			{
    				int[] tempDim = task[i];
    				Future f = es.submit(()->{
    					bobbleSort(tempDim);
    				});
    				System.out.println("f="+f.get());
    			}
    			es.shutdown();
    			for(int i=0;i<task.length;i++)
    			{
    				System.out.print("Dim:"+i+"=");
    				for(int j=0;j<task[i].length;j++)
    					System.out.print(task[i][j]+",");
    				System.out.println();
    			}
    		}
    		catch(Exception e)
    		{
    			e.printStackTrace();
    		}
    	}
    	
    	public static void main(String[] args)
    	{
    		int corePoolSize = 4;
    		int maximumPoolSize = 10;
    		long keepAliveTime = 10;
    		TimeUnit unit = TimeUnit.MINUTES;
    		BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<Runnable>(20);
    		ThreadFactory threadFactory = new MyThreadFactory();
    		RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy();
    		
    		int[][] tasks = {
    				{123,23,22,34,56,3,2,6,7,1,2,4,7,8,5,12,323},
    				{5,6,45,34,34,23,22,224,12,567,678,999,66,99},
    				{12,30,43,63,68,6,9,67,7,689,99,4,3,5,8,9,0},
    				{1,4,6,7,8,5,5,6,8,0,33,22,34,11,21,45,550,4},
    				{12,13,5,6,7,8,9,0,45,66,77,4,9,7,8,7,6,99,8},
    				{3,5,7,9,0,10,13,7,8,0,55,44,3,68,22,44,67,8}
    		};
    		
    		MyThreadPool mypool = new MyThreadPool(corePoolSize,maximumPoolSize,keepAliveTime,unit,workQueue,
    				threadFactory,handler,tasks);
    
    		for(int i=0;i<tasks.length;i++)
    		{
    			for(int j=0;j<tasks[i].length;j++)
    				System.out.println(tasks[i][j]);
    			System.out.println("------------");
    		}
    	}
    }
    
    class MyThreadFactory implements ThreadFactory
    {
    	@Override
    	public Thread newThread(Runnable r) {
    		return new Thread(r);
    	}
    }

思考题  
定义一个大数组，使用线程池最高效排序。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70]: /images/20230528/e25515e145724b68a3c784c535b89c26.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 1]: /images/20230528/ba4edcbbcf0b41059928b0e5644f3a0e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 2]: /images/20230528/6a31faeca921438dbaba455d2991dde3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 3]: /images/20230528/d6c537328e6242f78769ba2ecdb079b6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 4]: /images/20230528/d26377f0e63b40c2ba35221dffc10d00.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 5]: /images/20230528/1ec5df517d02410ea29dae0cac1e204c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 6]: /images/20230528/ad281879d2a7493c84ce0e49b67d512d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 7]: /images/20230528/f098b15ac0b648638affc5479824fe07.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 8]: /images/20230528/28ab40b238364b1d8284c9638fe59110.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 9]: /images/20230528/6910e71a12a34869ae62d08699011fe9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 10]: /images/20230528/28dff8dee05e4555a1eb7b6b65b04748.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpeGlhbmdfY2hlbg_size_16_color_FFFFFF_t_70 11]: /images/20230528/ac932ba3fdc34f2e8722fa2a33d44184.png