java开启新线程：🏝️

方法1：继承Thread类

1）：定义bai一个继承自Java.lang.Thread类的du类A.

2）：覆盖zhiA类Thread类中的run方法。

3）：我们编写需要在run方法中执行的操作：run方法中的代码，线程执行体。

4）：在main方法（线程）中，创建一个线程对象并启动线程。

(1)创建线程类对象:

A类 a = new A类();

(2)调用线程对象的start方法:

a.start();//启动一个线程

注意：不要调用run方法。如果run方法被称为对象调用方法，则仍然只有一个线程，并且没有启动新线程。

创建启动线程实例：

//定义一个类A 继承java.lang.Thread class A extends Thread{ //A类覆盖Thread类中的 run方法 @Override public void run(){ //在run方法填写要执行的操作 for (int j = 0 ;j<10;j++){ System.out.println("执行方法A的逻辑"+j); } } }





public Class B{
    public static void main(String[] args){
        for (int i = 0;i<50 ;i++){
            System.out.println(i);
            if(i==10){
                // 在线程中重开一个线程执行其他操作
                A a = new A();
                a.start();
            }
            try {
                if (i==10){
                    Thread.sleep(1000);
                }
            }catch (InterruptedException e){
                e.printStackTrace();
            }
        }
    }
}

方法2：实现Runnable接口

1）：定义要在java.lang.Runnable接口中实现的类A.请注意，A类不是线程类。

2）：覆盖A类Runnable接口中的run方法。

3）：我们编写需要在run方法中执行的操作：在run方法中，线程执行。

4）：在main方法（线程）中，创建一个线程对象并启动线程。

(1)创建线程类对象:

Thread t = new Thread(new A());

(2)调用线程对象的start方法:

t.start(); 代码实例：


//定义一个类C 实现java.lang.Runnable 接口 C类不是线程类
class C implements Runnable{
    //C类 覆盖Runnable接口中的 run方法
    @Override
    public void run(){
        //在run方法填写要执行的操作
        for (int j = 0 ;j<10;j++){
            System.out.println("执行方法C的逻辑"+j);
        }
    }
}
 
public Class B{
 
    public static void main(String[] args){
        for (int i = 0;i<100 ;i++){
            System.out.println(i);
            if(i==10){
                // 在线程中重开一个线程执行其他操作
                C c = new C();
                Thread t = new Thread(c);
                t.start();
            }
            try {
                if (i==10){
                    System.out.println(Thread.currentThread().getName());
                    Thread.sleep(1000);
                }
            }catch (InterruptedException e){
                e.printStackTrace();
            }
        }
    }
}

方法3：直接在函数体使用


    public static void main(String[] args){
 
        for (int i=0;i<20;i++){
            System.out.println(i);
            if(i==10){
 
                Thread thread = new Thread(new Runnable() {
                    @Override
                    public void run() {
                        for(int j=0;j<10;j++){
                            System.out.println("j"+j);
                        }
                    }
                });
                thread.start();
 
                try {
                    if (i==10){
                        System.out.println(Thread.currentThread().getName());
                        Thread.sleep(1000);
                    }
                }catch (InterruptedException e){
                    e.printStackTrace();
                }
            }
        }
 
    }

弊端：

1、每次都要new thread,新建了一个对象，导致对象性能差。

2、线程缺乏统一管理，可能无限制新建线程，相互之间出现竞争，极可能占用过多系统资源导致死机或者oom。

3、缺乏更多功能，比如：定时定时执行，定期执行，线程中断。

线程池

相比new Thread而言，Java提供的四种线程池的好处在于：

　　　①可复用存在的线程，减少对象的创建、消亡，性能较高。

　　　②有效控制并发线程数，提高了系统资源的使用率，避免了过多争夺系统资源，导致的堵塞。

　　　③提供了定时执行、定期执行、单线程、并发数控制等功能。

Java通过Executors提供了四种线程池：

newCachedThreadPool 创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。线程池的规模不存在限制。
newFixedThreadPool 创建一个固定长度线程池，可控制线程最大并发数，超出的线程会在队列中等待。
newScheduledThreadPool 创建一个固定长度线程池，支持定时及周期性任务执行。
newSingleThreadPool 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。
newCachedThreadPool:创建一个可缓存的线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，如无回收，则新建线程

newCachedThreadPool可缓存线程池


ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
  for(int i=0; i<10;i++){
     final int index=i;
      try{
             Thread.sleep(index*1000);
          }catch(InterruptedException e){
                e.printStackTrace();
          }
           cachedThreadPool.execute(new Runnable(){
                  @override
                      public  void  run(){
                             System.out.println(index);
                    }
            });
   }

特点：

核心线程数为零
最大线程数为无限
无任务时，线程存活的最大时间为60s
任务队列为同步移交队列，该队列没有缓冲区，即不会有任务会在该队列中排队，每当有任务要入队时，队列都会将任务移交给一个可用的线程

为什么叫缓存线程池，类比于redis缓存：

前者缓存的是频繁要用到的线程；后者缓存的是频繁要用到的数据

前者通过缓存线程，避免了每次执行任务都要创建、销毁线程的开销；后者通过缓存数据，避免了每次用到数据都要操作db

两者都有缓存失效的时间，前者对应keepAliveTime参数，超过该参数对应的时间后，销毁线程；后者当缓存对应的真实数据被修改时，缓存失效，清除数据

为了尽量重复利用缓存的线程，而不是每次要执行任务时创建新的线程，应尽量使执行任务的时间小于keepAliveTime参数，默认是60s

因为是一个“缓存”线程池，没有缓存可以永久有效，因此核心线程数为0。因此任务队列的缓冲区应为空，否则即便系统有可用的线程资源，当有新的任务时也不会被执行，而是进入任务队列排队直至队列满，这显然是不合理的。同样由于队列缓冲区为空，每来一个任务时，都会在必要时新建线程执行任务，这就有可能导致大量的线程被创建，进而系统瘫痪。

newFixedThreadPool定长线程池

创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待，定长线程池的大小最好根据系统资源进行设置。


ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
for (int i = 0; i < 10; i++) {
    final int index = i;
    fixedThreadPool.execute(new Runnable() {
 
        @Override
        public void run() {
            try {
                System.out.println(index);
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    });
}

newScheduledThreadPool周期线程池

创建一个定长线程池，支持定时及周期性任务执行，ScheduledExecutorService比Timer更安全，功能更强大。


ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
scheduledThreadPool.schedule(new Runnable() {
 
    @Override
    public void run() {
        System.out.println("delay 3 seconds");
    }
}, 3, TimeUnit.SECONDS);
此表示为延迟3秒执行
scheduledThreadPool.scheduleAtFixedRate(new Runnable() {
 
    @Override
    public void run() {
        System.out.println("delay 1 seconds, and excute every 3 seconds");
    }
}, 1, 3, TimeUnit.SECONDS);
此表示为延迟1秒后每3秒执行一次

newSingleThreadPool单线程线程池

创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序执行


ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
for (int i = 0; i < 10; i++) {
    final int index = i;
    singleThreadExecutor.execute(new Runnable() {
 
        @Override
        public void run() {
            try {
                System.out.println(index);
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    });
}

目录