定时器+线程池

超、凢脫俗 2022-10-19 11:30 199阅读 0赞

### 定时器+线程池 ###

*  定时器
 *  线程池
 *   *  创建
     *  Executors

# 定时器 #

定时器：定时器就像设置一个闹钟，当时间到达后完成某件事情，像JS中的是setTimeout。  
(JS中的setInterval是每隔多久执行一次)

1、我们使用定时器的时候，最主要的是小一个任务Runnable，TimeTask就实现了Runnable接口，所以我们直接创建一个Task。  
2、设置定时器：Timer timer = new Timer();

3、调度：利用timer.schedule()方法设置task和delay；  
schedule方法：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl81MjE0MjczMQ_size_16_color_FFFFFF_t_70]  
例如：会在5秒后打印：hello

public class Demo { 
        public static void main(String[] args) { 
            TimerTask task = new TimerTask() { 
                @Override
                public void run() { 
                    System.out.println("hello");
                }
            };
    
            Timer timer = new Timer();
            timer.schedule(task,5000);
        }
    }

scheduleAtFixedRate是周期性执行任务  
例如：timer.scheduleAtFixedRate(task,1000,2000);就是1秒后执行task，然后每隔2秒执行一次。

# 线程池 #

为什么需要线程池呢？  
如果每次来任务都创建一个新的线程，那么会造成很大的损失。  
如果可以将创建的线程放进线程池，下一次如果还需要这个线程，就可以直接使用。  
线程池的最大好处就是减少每次启动销毁的损耗

## 创建 ##

![在这里插入图片描述][20210710171035809.png]  
构造方法：  
![在这里插入图片描述][20210710171248924.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl81MjE0MjczMQ_size_16_color_FFFFFF_t_70 1]  
拒绝策略：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl81MjE0MjczMQ_size_16_color_FFFFFF_t_70 2]

## Executors ##

工厂类Executors，可以将new的步骤省略  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl81MjE0MjczMQ_size_16_color_FFFFFF_t_70 3]

Executors.newFixedThreadPool(3);
    //就是new一个固定大小的线程池
    
    Executors.newCachedThreadPool();
    //创建临时的

例如：利用线程池计算斐波那契数：

package threadpool;
    
    import java.util.Scanner;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class Demo { 
        public static void main(String[] args) { 
            ExecutorService pool = Executors.newFixedThreadPool(3);
            Scanner sc = new Scanner(System.in);
            System.out.println("请输入:");
            while (sc.hasNextInt()) { 
                int n = sc.nextInt();
                Runnable runnable = new Runnable() { 
                    @Override
                    public void run() { 
                        long r = fib(n);
                        System.out.printf("fib(%d) = %d\n", n, r);
                    }
                };
    
                pool.execute(runnable);
                System.out.println("请输入:");
            }
        }
    
    
        private static int fib(int n) { 
            if (n < 2) { 
                return n;
            }
            return fib(n - 1) + fib(n - 2);
        }
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl81MjE0MjczMQ_size_16_color_FFFFFF_t_70]: /images/20221005/7c104e233f53442c9f53eca53d270b02.png
[20210710171035809.png]: /images/20221005/3af7b91652cc488094872ca21b3838b3.png
[20210710171248924.png]: /images/20221005/68b9f7c99ca54dd9bad1a1ff7b7d7e7b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl81MjE0MjczMQ_size_16_color_FFFFFF_t_70 1]: /images/20221005/1dd66f8e891d406da337583eb5451485.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl81MjE0MjczMQ_size_16_color_FFFFFF_t_70 2]: /images/20221005/bfa948a166fc4eefae8bd1328fc5cc77.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl81MjE0MjczMQ_size_16_color_FFFFFF_t_70 3]: /images/20221005/0606f987e5cf4a0995b9bb7a97294a9e.png