Java—多线程创建详解

2020-09-08  本文已影响0人  Hughman

关注:CodingTechWork,一起学习进步。

多线程介绍

线程和进程

进程

线程

进程和线程的关系

  1. 一个线程只能属于一个进程,而一个进程可以有多个线程,但至少有一个线程。
  2. 资源分配给进程,同一进程的所有线程共享该进程的所有资源。
  3. 处理机分给线程,即真正在处理机上运行的是线程。
  4. 线程在执行过程中,需要协作同步。不同进程的线程间要利用消息通信的办法实现同步。

多线程的优势

  1. 性能高:进程之间不能够共享内存,同一进程下的多线程之间可以共享内存,极大提高程序的运行效率。多线程共享同一个进程的虚拟空间,线程共享环境主要包括进程代码段和进程的公有数据,便于实现线程间的通信。
  2. 开销小:系统创建进程是需要为该进程重新分配系统资源,创建进程的开销比较大。相对而言,创建线程的代价就小很多,使用的多线程并发多任务比多进程效率高。
  3. 编程简易:Java内置多线程功能,编程简易。

多线程实现方式

多线程实现的三种方式

1)继承Thread类创建线程类;
2)实现Runnable接口创建线程类;
3)使用CallableFuture创建线程。

继承Thread类创建线程类

继承Thread类步骤

  1. 定义Thread类的子类,并重写该类的run()方法,该run()方法的方法体就代表线程需要完成的任务。run()即为线程执行体;
  2. 创建Thread子类的实例,即创建线程对象;
  3. 调用线程对象的start()方法来启动该线程。

常用方法

示例

代码


public class ThreadTest extends Thread {
    private int i;

    @Override
    public void run() {
        for(; i < 2; i++) {
            System.out.println("继承Thread启动线程:" + getName() + " : " + i);
        }
        setName("Thread-new");
        for(; i < 4; i++) {
            System.out.println("重命名后的新线程名:" + Thread.currentThread().getName() + " : " + i);
        }
    }


    public static void main(String[] args) {
        System.out.println("main线程:" +Thread.currentThread().getName());
        new ThreadTest().start();
    }
}

运行结果

main线程:main
继承Thread启动线程:Thread-0 : 0
继承Thread启动线程:Thread-0 : 1
重命名后的新线程名:Thread-new : 2
重命名后的新线程名:Thread-new : 3

实现Runnable接口创建线程类

实现Runnable接口步骤

  1. 定义Runnable接口的实现类,并重写该接口的run()方法,该run()是线程执行体;
  2. 创建Runnable实现类的实例,并以此实例作为Thread的target来创建Thread对象,该Thread对象才是真正的线程对象;
  3. 调用线程对象的start()方法来启动该线程。

注意
实现Runable接口和继承Thread的方式区别:继承Thread创建的线程是创建的Thread子类即可代表线程对象;而实现Runable接口的创建的Runnable对象只能作为线程对象的target。

示例

代码

public class RunnableTest implements Runnable {

    private int i;

    @Override
    public void run() {

        //不能直接调用getName()和setName()方法,Runnable只有run方法
        for(; i < 5; i++) {
            System.out.println("实现Runnable接口创建线程:" + Thread.currentThread().getName() + " : " + i);
        }
    }

    public static void main(String[] args) {
        System.out.println("main线程:" +Thread.currentThread().getName());
        RunnableTest runnableTest = new RunnableTest();
        new Thread(runnableTest).start();

        //指定线程名称
        RunnableTest runnableTestWithNewName = new RunnableTest();
        new Thread(runnableTestWithNewName, "Runnable-Thread-new").start();
    }
}

常用方法

运行结果

main线程:main
实现Runnable接口创建线程:Thread-0 : 0
实现Runnable接口创建线程:Thread-0 : 1
实现Runnable接口创建线程:Thread-0 : 2
实现Runnable接口创建线程:Runnable-Thread-new : 0
实现Runnable接口创建线程:Thread-0 : 3
实现Runnable接口创建线程:Runnable-Thread-new : 1
实现Runnable接口创建线程:Thread-0 : 4
实现Runnable接口创建线程:Runnable-Thread-new : 2
实现Runnable接口创建线程:Runnable-Thread-new : 3
实现Runnable接口创建线程:Runnable-Thread-new : 4

使用Callable和Future创建线程

使用Callable和Future步骤

  1. 创建Callable接口的实现类,并实现call()方法,该call()方法即为线程执行体,且该call()方法有返回值,再创建Callable实现类的实例;
  2. 使用FutureTask类包装Callable对象,该FutureTask对象封装了该Callable对象的call()方法的返回值;
  3. 使用FutureTask对象作为Thread对象的target创建并通过线程对象的start()方法启动线程;
  4. 调用FutureTask对象的get()方法获得子线程执行结束后的返回值。

示例

代码

public class CallableFutureTest implements Callable<Integer>{

    private int i;

    @Override
    public Integer call(){
        for (i = 0; i < 2; i++) {
            System.out.println("实现Callable接口创建线程: " + Thread.currentThread().getName() + " : " + i);
        }
        return i;
    }

    public static void main(String[] args) {
        System.out.println("main线程:" +Thread.currentThread().getName());

        long begin = System.currentTimeMillis();
        ExecutorService executorService = Executors.newCachedThreadPool();
        CallableFutureTest callableFutureTest1 = new CallableFutureTest();
        CallableFutureTest callableFutureTest2 = new CallableFutureTest();
        FutureTask<Integer> futureTask1 = new FutureTask<>(callableFutureTest1);
        FutureTask<Integer> futureTask2 = new FutureTask<>(callableFutureTest2);
        executorService.submit(futureTask1);
        executorService.submit(futureTask2);
        try {
            System.out.println("futureTask1: "+ futureTask1.get() + "-futureTask2: " + futureTask2.get());
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }finally {
            executorService.shutdown();
        }
        System.out.println("executor pool: " + executorService.isShutdown());
        System.out.println("time: " + (System.currentTimeMillis() - begin));
        
    }

}

运行结果

main线程:main
实现Callable接口创建线程: pool-1-thread-1 : 0
实现Callable接口创建线程: pool-1-thread-2 : 0
实现Callable接口创建线程: pool-1-thread-1 : 1
实现Callable接口创建线程: pool-1-thread-2 : 1
futureTask1: 2-futureTask2: 2
executor pool: true
time: 5

Q&A

并行和并发的区别

并行:parallelism,物理上同时执行;多个处理器同时处理多条指令;(单线程永远无法达到并行状态)
并发:concurrency,逻辑上多个任务交织执行;多个进程指令交替执行,同一时刻只有一条指令执行。(宏观上给人一种错觉是多个进程同时执行)

进程与线程的区别

  1. 调度:线程作为调度的基本单位;进程是资源分配的基本单位。
  2. 并发性:不仅进程之间可以并发执行;同一个进程的多个线程之间也可并发执行。
  3. 拥有资源:进程是拥有资源的一个独立单位,线程不拥有系统资源,但可以访问隶属于进程的资源;
  4. 系统开销:在创建或撤消进程时,由于系统都要为之分配和回收资源,导致系统的开销明显大于创建或撤消线程时的开销。但是进程有独立的地址空间,一个进程崩溃后,在保护模式下不会对其它进程产生影响。
    线程只是一个进程中的不同执行路径。线程有自己的堆栈和局部变量,但线程之间没有单独的地址空间,一个进程死掉就等于所有的线程死掉,所以多进程的程序要比多线程的程序健壮,但在进程切换时,耗费资源较大,效率要差一些。
  5. 作用:多进程作用是提高CPU的使用率,而不是提高执行速度;
    多线程作用是提高应用程序的使用率,而不是提高执行速率。

结论:

  1. 线程是进程的一部分。
  2. CPU调度的是线程。
  3. 系统为进程分配资源,不对线程分配资源。

三种实现线程方式的区别

  1. 返回值:继承Thread类,run()方法没有返回值;实现Runnable接口和Callable接口方式基本相同,但Callable接口定义的call()方法具有返回值,可以声明抛出异常。
  2. 继承:继承Thread类,不能再继承其他类;线程类实现Runnable和Callable接口可以继承其他类。
  3. 访问当前线程:继承Thread类,需要访问当前线程,无须使用Thread.currentThread()方法,直接使用this即可获得当前线程;线程类实现Runnable和Callable接口,若访问当前线程,必须使用Thread.currentThread()方法。多个线程共享同一个target对象,适合多个相同线程来处理同一份资源的情况,从而将CPU、代码和数据分开,形成清晰的模型,较好地体现面向对象思想。

综合:推荐使用线程类实现Runnable和Callable接口方式创建多线程。

参考书籍
《疯狂Java》
《并发编程实战》

上一篇下一篇

猜你喜欢

热点阅读