• Java多线程编程


    多线程编程细节1:Thread

    1,Thread类实现了Runnable接口,所以Thread对象也是可运行Runnable对象,
     * 同时Thread类也是线程类
     * Thread类定义
     * Thread()//一般用于在Thread类中覆盖定义run方法,可以使用匿名内部类进行定义
     * Thread(Runnable)//使用最多的情况,run方式是由Runnable参数对象提供
     * Thread(String name) //自定义线程名称
     * Thread(Runnable,String name)
     * 由于Runnable接口属于函数式接口,所以一般使用简化写法
         Thread t = new Thread(()->{
        System.out.println(Thread.currentThread());
    });
    t.start();


    常见方法:

    |               方法                    | 说明                                                                                                |
    | :------------------------------:    | ------------------------------------------------------------                               |
    |           void start()               | 使该线程开始执行,注意不是立即执行,不是一般方法调用;Java 虚拟机调用该线程的 run 方法                                                        |
    |            void run()                | 线程的执行体                                                                                 |
    |       void setName(String)  | 改变线程名称                                                                                  |
    |      void setPriority(int)       | 更改线程的优先级,Java中线程的优先级可以分为1-10,默认为5 |
    |     void setDaemon(boolean) | 设置守护线程,守护线程是一种用于提供服务的线程,一般线程 体中使用的是死循环,会在所有非守护线程退出后自动关闭     |
    |   void join()/(long millisec)  | 等待该线程终止的时间最长为 millis 毫秒                                      |
    |         void interrupt()            | 中断线程,不是中断线程的执行,而是修改中断参数                   |
    |        boolean isAlive()          | 测试线程是否处于活动状态,活动状态就是线程已经启动且尚未终止。线程处于正在运行或准备开始运行的状态,就认为线程是“存活”的 |
    |       static void yield()          | 暂停当前正在执行的线程对象,并执行其他线程                          |
    | static void sleep(long millisec) | 在指定的毫秒数内让当前正在执行的线程休眠(暂停执行),此操作受到系统计时器和调度程序精度和准确性的影响              |
    |  static Thread currentThread()   | 返回对当前正在执行的线程对象的引用                                 |
     

    2,java针对线程提供了10级优先,优先级越高则获取更多的运行机会
     * 但是不同的操作系统不一定恰好支持10级优先,所以设置优先级时可
     * 能会出现在Java中的不同优先级映射到操作系统中相同的优先级上。
     * 在具体编程中如果需要使用优先级,则建议将优先级的差距拉开
     * 
     * Thread类中定义了3个常量
     *  public static final int MIN_PRIORITY = 1;  最小优先级
     *  public static final int NORM_PRIORITY = 5;  默认优先级
     *  public static final int MAX_PRIORITY = 10;  最大优先级


     3,* void join()/(long millisec) 等待该线程终止的时间最长为 millis 毫秒
     * 
     *  while (isAlive()) {
                    long delay = millis - now;
                    if (delay <= 0) {
                        break;
                    }
                    wait(delay);
                    now = System.currentTimeMillis() - base;
                }
    4, void interrupt()中断线程,不是中断线程的执行,而是修改中断参数
       具体实现是依赖于调用interrupt方法后产生InterruptedException实现的。

    5,boolean isAlive()测试线程是否处于活动状态,活动状态就是线程已经启动且尚未终止。线程处于正在运行或准备开始运行的状态,就认为线程是“存活”的。

    多线程编程细节2:Runnable和Callable

    1,Runnable接口
     *Runnable接口只定义了一个方法public void run(),这个方法要求实现
     *Runnable接口的类实现,Runnable对象称为可运行对象,一个线程的运行
     *就是执行该对象的run()方法
     *run()方法没有返回值void,而且不能抛出异常
     *Thread类中的定义
     * private Runnable target;
     * @Override
        public void run() {
            if (target != null) {
                target.run();
            }
        }

    2,

    ### Callable接口

    继承Thread或实现Runnable接口这2种方式都有一个缺陷就是:在执行完任务之后无法
    获取执行结果。 

    如果需要获取执行结果,就必须通过共享变量或者使用线程通信的方式来达到效果,这样
    使用起来就比较麻烦。

    call()方法有返回值,这个返回值可以通过泛型进行约束,允许抛出异常

    3,### Future接口
     * Future表示一个任务的生命周期,并提供了方法来判断是否已经完成或取消以及获取任务
     * 的结果和取消任务等
     * 
     * Future就是对于具体的Runnable或者Callable任务的执行结果进行取消、查询是否完成、
     * 获取结果。必要时可以通过get方法获取执行结果,该方法会阻塞直到任务返回结果。
     * 
     * - cancel方法用来取消任务,如果取消任务成功则返回true,如果取消任务失败则返回
     * false。参数mayInterruptIfRunning表示是否允许取消正在执行却没有执行完毕的任务
     * ,如果设置true,则表示可以取消正在执行过程中的任务。如果任务已经完成,则无论
     * mayInterruptIfRunning为true还是false,此方法肯定返回false,即如果取消已经完
     * 成的任务会返回false;如果任务正在执行,若mayInterruptIfRunning设置为true,则
     * 返回true,若mayInterruptIfRunning设置为false,则返回false;如果任务还没有
     * 执行,则无论mayInterruptIfRunning为true还是false,肯定返回true
     * 
     * - isCancelled方法表示任务是否被取消成功,如果在任务正常完成前被取
     * 消成功,则返回 true
     * 
     * - isDone方法表示任务是否已经完成,若任务完成,则返回true
     * 
     * 
     * 有用的方法
     * - get()方法用来获取执行结果,这个方法会产生阻塞,会一直等到任务执行完毕
     * 才返回
     * - get(long timeout, TimeUnit unit)用来获取执行结果,如果在指定时间内,
     * 还没获取到结果,就抛出TimeoutException超时异常。 

     * Future接口的具体实现类
     * public class FutureTask implements RunnableFuture
     * public interface RunnableFuture extends Runnable, Future {
        void run();
    }
     * public FutureTask(Callable callable) {
            if (callable == null)
                throw new NullPointerException();
            this.callable = callable;
            this.state = NEW;       // ensure visibility of callable
        }

    4,

     FutureTask
     * 具体使用
    FutureTask future = new FutureTask(callable);
    new Thread(future).start();
    FutureTask实现了两个接口,Runnable和Future,所以它既可以作为Runnable被线程执行,
    又可以作为Future得到Callable的返回值

    FutureTask是一个可取消的异步计算,FutureTask实现了Future的基本方法,提供start 
    cancel 操作,可以查询计算是否已经完成,并且可以获取计算的结果。结果只可以在计算
    完成之后获取,get方法会阻塞当计算没有完成的时候,一旦计算已经完成, 那么计算就
    不能再次启动或是取消。

    一个FutureTask 可以用来包装一个 Callable 或是一个Runnable对象。因为FurtureTask
    实现了Runnable方法,所以一个 FutureTask可以提交(submit)给一个Excutor执行(excution). 
    它同时实现了Callable, 所以也可以作为Future得到Callable的返回值。
    5, 

  • 相关阅读:
    Response Status Code 301、302
    gRPC 应用指引
    CTF是黑客大赛?新手如何入门CTF?
    linux系统备份及还原
    阿里云服务器带宽可以修改吗?不够用怎么办?
    SMOKE 单目相机 3D目标检测【训练模型】
    【软考 系统架构设计师】软件架构设计⑥ 软件产品线
    ABAP 面试题:如何使用 ABAP 编程语言的 System CALL 接口,直接执行 ABAP 服务器所在操作系统的 shell 命令?
    hive建表指定列分隔符为多字符分隔符实战(默认只支持单字符)
    socket报错:bind:address already in use
  • 原文地址:https://blog.csdn.net/zjh0101/article/details/126374660