java并发编程01:进程与线程

1、进程与线程

进程:是并发执行的程序在执行过程中分配和管理资源的基本单位,竞争计算机系统资源的基本单位。正在运行的程序实例,进程是线程的容器,即一个进程中可以开启多个线程。比如打开浏览器、word等操作,都会创建进程。

线程:是进程内部一个独立执行单元;一个进程可以同时并发运行多个线程,类似于工厂里的工人,工人把工厂按照一定的规则继续运行下去。

一个程序由一个或多个进程组成,一个进程由一个或多个线程组成。

进程与线程的区别?

1、地址空间:进程之间是独立的地址空间,但同一进程的线程共享本进程的地址空间。

2、资源占用:同一进程内的线程共享本进程的资源如内存(堆,方法区)、I/O、cpu等,但是进程之间的资源是独立的。

3、健壮性:因为同一进程的所以线程共享此线程的资源,因此当一个线程发生崩溃时,此进程也会发生崩溃。 但是各个进程之间的资源是独立的,因此当一个进程崩溃时,不会影响其他进程。因此进程比线程健壮。

4、执行过程:每个独立的进程程有一个程序运行的入口、顺序执行序列和程序入口。但是线程不能独立执行,必须依存在应用程序中,由应用程序提供多个线程执行控制。

进程与线程的选择取决条件?

进程是资源分配的基本单位,线程是程序执行的最小单位

1、在程序执行过程中,如果需要频繁创建和销毁的使用线程。因为进程的创建和销毁开销很大(需要不停的分配资源),但是线程频繁的调用只是改变CPU的执行,开销大小。

2、如果需要程序更加的稳定安全时,可以选择进程。如果追求速度,就选择线程。

2、并发与并行

想要学习多线程,必须先理解什么是并发与并行

并行:当系统有一个以上CPU时,则线程的操作有可能非并发。当一个CPU执行一个线程时,另一个CPU可以执行另一个线程,两个线程互不抢占CPU资源,可以同时进行.

并发:当有多个线程在操作时,如果系统只有一个CPU,则它根本不可能真正同时进行一个以上的线程,它只能把CPU运行时间划分成若干个时间段,再将时间 段分配给各个线程执行,在一个时间段的线程代码运行时,其它线程处于挂起状。

① 程序与计算不再一一对应,一个程序副本可以有多个计算
② 并发程序之间有相互制约关系,直接制约体现为一个程序需要另一个程序的计算结果,间接制约体现为多个程序竞争某一资源,如处理机、缓冲区等。
③ 并发程序在执行中是走走停停,断续推进的。

并发连接数

防火墙,所能处理的最大会话数量,就是“并发连接数”。

 3、线程创建

Java中线程有4种创建方式

  1. 继承Thread类
  2. 实现Runnable接口
  3. 实现Callable接口
  4. 线程池

3.1 继承Thread类

创建和自定义线程类

/**
 * @Auther: mengyang
 * @Date: 2020/1/19 0020 21:20
 * @Description: 继承Thread类实现多线程
 * @statement:
 */
public class MyThread extends Thread {

    public void run(){
        for (int i=0;i<10;i++){
            System.out.println("myThread线程正在执行:"+i);
        }
    }

    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        myThread.start();

        for (int i = 0;i<10;i++) {
            System.out.println("主进程正在执行:"+i);
        }
    }
}

执行效果如下:

 3.2 实现Runnable接口

创建自定义类实现Runnable接口

package com.mall.thread;

/**
 * @Auther: mengyang
 * @Date: 2020/1/19 0020 21:20
 * @Description: 实现Runnable接口实现多线程
 * @statement:
 */
public class MyRunnable implements Runnable{

    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            System.out.println("myRunnable线程正在执行:"+i);
        }
    }


    //测试线程
    public static void main(String[] args) {
        Thread thread = new Thread(new MyRunnable());
        thread.start();

        for (int i = 0; i < 10; i++) {
            System.out.println("主线程正在执行:"+i);
        }
    }
}

执行效果:

 3.3 实现Runnable接口

3.3.1 FutureTask介绍

Callable需要使用FutureTask类帮助执行,FutureTask类结构如下:

Future接口:

判断任务是否完成:isDone()

能够中断任务:cancel()

能够获取任务执行结果:get()

3.3.2.   第一步:创建自定义类实现Callable接口
package com.mall.thread;

import java.util.concurrent.*;

/**
 * @Auther: mengyang
 * @Date: 2020/1/20 0020 14:37
 * @Description: 实现callable接口创建线程
 * @statement: callable接口是有返回值的
 */
public class MyCallnable implements Callable<String> {

    public String call() throws Exception {
        for (int i = 0; i < 10; i++) {
            System.out.println("myCallable线程正在执行:"+i);
        }
        return "MyCallabe线程执行完毕";
    }

    //测试
    public static void main(String[] args) {
        //创建futuretask对象
        FutureTask<String> futureTask = new FutureTask<String>(new MyCallnable());
        //创建Thread对象,传入futureTask
        Thread thread=new Thread(futureTask);
        thread.start();
        for (int i = 0; i<10; i++){
            System.out.println("主线程正在执行:"+i);
        }
    }
}

运行效果如下:

3.4. 线程池-Executor

3.4.1.   线程池线类关系图

Executor接口

  声明了execute(Runnable runnable)方法,执行任务代码

ExecutorService接口:

  继承Executor接口,声明方法:submit、invokeAll、invokeAny以及shutDown等

AbstractExecutorService抽象类:

  实现ExecutorService接口,基本实现ExecutorService中声明的所有方法

ScheduledExecutorService接口:

  继承ExecutorService接口,声明定时执行任务方法

ThreadPoolExecutor类:

  继承类AbstractExecutorService,实现execute、submit、shutdown、shutdownNow方法

ScheduledThreadPoolExecutor类:

  继承ThreadPoolExecutor类,实现ScheduledExecutorService接口并实现其中的方法

Executors类:

  提供快速创建线程池的方法

3.4.2.   第一步:创建自定义类实现Runnable接口
package com.mall.thread;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @Auther: mengyang
 * @Date: 2020/1/20 0020 14:43
 * @Description:使用线程池创建线程
 * @statement:
 */
public class MyExecutors {

    //实现runnable接口,线程池只支持runnable和callable
    static class MyRunnable implements Runnable{
        public void run() {
            for (int i = 0; i<10; i++){
                System.out.println("myRunnable线程正在执行:"+i);
            }
        }
    }

    //测试用线程池创建线程
    public static void main(String[] args) {
        //1.使用Executors创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        //2.通过线程池执行线程,线程池只支持runnable和callable
        executorService.execute(new MyRunnable());
        //3.主线程循环打印
        for (int i=0; i<10; i++){
            System.out.println("main主线程正在执行:"+i);
        }
    }

}
实现效果如下:

 4、小结

4.1.   实现接口和继承Thread类比较

l  接口更适合多个相同的程序代码的线程去共享同一个资源。

l  接口可以避免java中的单继承的局限性。

l  接口代码可以被多个线程共享,代码和线程独立。

l  线程池只能放入实现Runable或Callable接口的线程,不能直接放入继承Thread的类。

扩充:

在java中,每次程序运行至少启动2个线程。一个是main线程,一个是垃圾收集线程。

4.2.   Runnable和Callable接口比较

相同点:

l  两者都是接口;

l  两者都可用来编写多线程程序;

l  两者都需要调用Thread.start()启动线程;

不同点:

l  实现Callable接口的线程能返回执行结果;而实现Runnable接口的线程不能返回结果;

l  Callable接口的call()方法允许抛出异常;而Runnable接口的run()方法的不允许抛异常;

l  实现Callable接口的线程可以调用Future.cancel取消执行 ,而实现Runnable接口的线程不能

注意点:

Callable接口支持返回执行结果,此时需要调用FutureTask.get()方法实现,此方法会阻塞主线程直到获取‘将来’结果;当不调用此方法时,主线程不会阻塞!

参考:https://www.cnblogs.com/zeussbook/p/11895829.html

原文地址:https://www.cnblogs.com/mengY/p/12202099.html