Java线程池与Lambda表达式

Java线程池

有没有一种方法使得线程可以复用(反复使用)，就是执行完一个任务，并不被销毁，而是可以继续执行其它的任务？

在Java中可以通过线程池来达到这样的效果

线程池：其实就是一个容纳多个线程的容器，其中的线程可以反复使用，省去了频繁创建线程对象的操作，无需反复创建线程而消耗过多资源

线程池：容器–>集合（ArrayList、Hashset、Linkedlist hashmap）

Java.util.concurrent.Executors:线程池的工厂类，用来生成线程池

Executors类中的静态方法：

  static ExecutorService newFixedThreadPool(int nThreads)创建一个可重用固定线程数的线程池参数：int nThreads:创建线程池中包含的线程数量返回值：ExecutorService接口：返回的是ExecutorService接口的实现类对象，我们可以使ExecutorService接口接收(面向接口编程)java.util.concurrent.ExecutorService:线程池接口用来从线程池中获取线程，调用start方法，执行线程任务submit(Runnable task) 提交一个Runnable任务用于执行关闭/销毁线程池的方法void shutdown()

线程池的使用步骤：

1.使用线程池的工厂类Executors里边提供的静态方法newFixedThreadPool生产一个指定线程数量的线程池

2.创建一个类，实现Runnable接口，重写run方法，设置线程任务

3.调用ExecutorService中的方法submit()，传递线程任务（实现类），开启线程，执行run方法

4.调用ExecutorService中的方法shutdown()销毁线程池（不建议执行）

 public static void main(String[] args) {//1.使用线程池的工厂类Executors里边提供的静态方法newFixedThreadPool生产一个指定线程数量的线程池ExecutorService es= Executors.newFixedThreadPool(2);//3.调用ExecutorService中的方法submit()，传递线程任务（实现类），开启线程，执行run方法es.submit(new Runnableimpl());//pool-1-thread-1新线程//线程池会一直开启，使用完了线程，会自动把线程归还给线程池，线程可以继续使用es.submit(new Runnableimpl());//pool-1-thread-2新线程//4.调用ExecutorService中的方法shutdown()销毁线程池（不建议执行）es.shutdown();es.submit(new Runnableimpl());//线程池已销毁，抛异常，就不能获取线程了}

//2.创建一个类，实现Runnable接口，重写run方法，设置线程任务
public class Runnableimpl implements Runnable{@Overridepublic void run(){System.out.println(Thread.currentThread().getName()+"新线程");}
}

Lambda表达式

函数式的编程思想：

面向对象过分强调“必须通过对象的形式来做事情”，而函数式思想则尽量忽略面向对象的复杂语法–强调做什么，而不是以什么形式做

面向对象的思想：

做一件事情，找一个能解决这个事情的对象，调用对象的方法，完成事情

函数式编程思想：

只要能获取到结果，谁去做的，怎么做的都不重要，重视的是结果，不重视过程

Thread类的匿名内部类用法

1.Thread类需要Runnable接口作为参数，其中的抽象run方法是用来指定线程任务内容的核心
2.为了指定run的方法体，不得不需要Runnable接口的实现类
3.为了省去定义一个Runnableimpl实现类的麻烦，不得不使用匿名内部类
4.必须覆盖重写抽象run方法，所以方法名称、方法参数、方法返回值不得不再写一遍，且不能写错
5.而实际上，似乎只有方法体才是关键所在

 public static void main(String[] args){Runnableimpl run=new  Runnableimpl();Thread t=new Thread(run);t.start();//简化代码，使用匿名内部类，实现多线程程序Runnable r = new Runnable(){@Overridepublic void run() {System.out.println(Thread.currentThread().getName()+"新线程");}};new Thread(r).start();//简化代码new Thread(new Runnable(){@Overridepublic void run() {System.out.println(Thread.currentThread().getName()+"新线程");}}).start();//使用Lambda表达式，实现多线程new Thread(()->{System.out.println(Thread.currentThread().getName()+"新线程");}).start();}

public class Runnableimpl implements Runnable{@Overridepublic void run(){System.out.println(Thread.currentThread().getName()+"新线程");}
}