Callable方式创建线程

🕗 发布于 2024-01-16 12:33 python 开发语言

方式一：

1.先定义Callable对象，用于编写线程要执行代码(用call方法表示，此方法有返回值)

2.定义FutureTask对象封装Callable对象

3.定义Thread对象封装FutureTask对象, 并调用Thread对象的start()方法

具体代码如下：

package demo;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class Test {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        MyCallable t1=new MyCallable();
        FutureTask task1=new FutureTask(t1);
        Thread thread1=new Thread(task1,"T1");
        thread1.start();

        MyCallable t2=new MyCallable();
        FutureTask task2=new FutureTask(t2);
        Thread thread2=new Thread(task2,"T2");
        thread2.start();

        System.out.println(task1.get());
        System.out.println(task2.get());
        //注意：thread1和thread2最好分别执行两个task对象(两个task对象也分别采用两个Callable对象，否则只会有一个线程执行)
    }
}

class MyCallable  implements Callable<Integer>{
    public Integer call() throws Exception {
        int i=0;
        for(;i<10000;i++) {
            System.out.println(Thread.currentThread().getName()+" "+i);
        }
        return i;
    }
}

方式二：

2.1.newFixedThreadPool线程池的概述

newFixedThreadPool是Java中的一个线程池类，它是一个固定大小的线程池，线程的数量在创建线程池时就已经确定。线程池中的线程数量一旦被确定，就不会发生改变。在Java中，newFixedThreadPool()方法创建的线程池是一个固定大小的线程池，线程池中的线程数量是固定的，由构造函数传入的参数指定，而任务队列的大小则由内部的阻塞队列来决定。

在使用newFixedThreadPool()方法创建线程池时，它使用的是LinkedBlockingQueue，这是一个无界的阻塞队列，它的大小是没有限制的。因此，当任务提交到线程池时，如果线程池中的线程正在执行任务，那么新提交的任务将被放入LinkedBlockingQueue中等待执行，直到有可用的线程来执行任务。当队列已经满了时，新提交的任务将会被阻塞，直到有空闲线程来处理队列中的任务。

因此，使用newFixedThreadPool()方法创建线程池时，队列的大小实际上是无限制的，但是需要注意的是，如果任务提交速度过快，队列可能会无限制地增长，导致内存溢出等问题。因此，在实际使用中需要根据具体的场景来合理设置线程池的大小和任务队列的容量，以充分利用系统资源并保证系统的稳定性。

2.2.newFixedThreadPool线程池的优缺点：

A.优点

简单易用：newFixedThreadPool是Java内置的线程池，使用起来非常简单，不需要手动创建线程、管理线程、调度线程等。
稳定性好：newFixedThreadPool是一个固定大小的线程池，线程数量不会发生变化，因此稳定性较好，不容易因线程数量过多导致系统崩溃。
高效性：newFixedThreadPool在任务队列中维护了一个阻塞队列，可以很好地处理大量的并发请求，提高了程序的效率和性能。
良好的可扩展性：newFixedThreadPool可以通过修改线程池中的线程数量来适应不同的系统负载，提高了系统的可扩展性。

B.newFixedThreadPool的缺点

线程数固定：newFixedThreadPool创建时需要指定线程数量，线程数量不能动态调整，因此无法适应不同的系统负载。
队列长度有限：newFixedThreadPool使用阻塞队列存储任务，队列长度有限，如果队列已满，新的任务将无法提交，可能会导致任务丢失。
任务执行时间不可控：newFixedThreadPool无法控制任务执行的时间，如果任务执行时间过长，会导致其他任务等待的时间过长，降低程序的效率和性能。

2.3.线程池的两种主要任务提交方法:

在Java中，线程池的两种主要任务提交方法是execute()和submit()。它们虽然都是将任务提交到线程池中，但是在使用上有一些区别。

返回值类型不同

execute()方法没有返回值，而submit()方法会返回一个Future对象，可以通过这个对象获取任务的执行结果。

异常处理不同

execute()方法中如果任务执行过程中发生了异常，则异常会被传递到任务提交的地方，并由任务提交的线程来处理。而submit()方法中，如果任务执行过程中发生了异常，异常将被封装在Future对象中，直到调用Future.get()方法时才会将异常抛出。

任务参数不同

execute()方法只能接受Runnable类型的任务，而submit()方法既可以接受Runnable类型的任务，也可以接受Callable类型的任务。

提交方式不同

execute()方法是一种异步提交方式，即提交任务后立即返回，不会等待任务执行完成。而submit()方法是一种同步提交方式，即提交任务后会阻塞当前线程，直到任务执行完成。

能否取消任务

submit()方法返回的Future对象可以用来取消任务，而execute()方法没有提供取消任务的方法。

总之，execute()方法比submit()方法更简单，适用于不需要处理返回值的情况，而submit()方法则更为灵活，可以处理返回值，并且支持取消任务等操作。

用Callable创建的线程在线程池中运行，不需要FutureTask对象也不需要Thread对象

可以两个线程可以采用同一个Callable对像，也可以一个线程采用一个Callable对像

package demo;

import java.util.concurrent.*;

//用Callable创建的线程在线程池中运行
public class Test {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        MyCallable c1=new MyCallable();
        //MyCallable c2=new MyCallable();

        ExecutorService service= Executors.newFixedThreadPool(2);
        //线程池的方式可以两个线程可以采用同一个Callable对像，也可以一个线程采用一个Callable对像
        Future<Integer> f1=service.submit(c1);//不需要FutureTask对象也不需要Thread对象
        Future<Integer> f2=service.submit(c1);

        Integer rs1=f1.get();
        System.out.println(rs1);
        Integer rs2=f2.get();
        System.out.println(rs2);

        //service.shutdown();//关闭线程池
    }
}

class MyCallable  implements Callable<Integer>{
    public Integer call() throws Exception {
        int i=0;
        for(;i<100;i++) {
            System.out.println(Thread.currentThread().getName()+" "+i);
        }
        return i;
    }
}

用Runnable方式创建线程要执行的任务提交给newFixedThreadPool线程池来执行，代码如下：

package demo;

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

//使用newFixedThreadPool线程池
public class Test {
    public static void main(String[] args) {
        ExecutorService service= Executors.newFixedThreadPool(3);//创建
        service.execute(new Task());//提交要执行的任务(此任务会由线程池的某一个线程来运行)
        service.execute(new Task());//提交要执行的任务(此任务会由线程池的另一个线程来运行)
        //service.shutdown();//关闭线程池
    }
}

class Task implements  Runnable{
    public void run() {
        for(int i=1;i<=5;i++){
            System.out.println(Thread.currentThread().getName()+":run"+i);
        }
    }
}

原文地址：https://blog.csdn.net/gulanga5/article/details/135620814

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：【C语言】字符函数和字符串函数
下一篇：网络安全B模块（笔记详解）- MYSQL信息收集

UML概述、类图关系及连接线表示
继承和实现体现的是一种类与类、或者类与接口间的纵向关系;依赖关联聚合组合体现的是类与类、类与接口间的引用，即横向关系;这几种关系，所表现的强弱程度依次为：组合 > 聚合 > 关联 >
阅读更多2024-11-17
131. HTML标签遮挡Canvas画布事件
HTML元素标签外面div父元素遮挡了Canvas画布鼠标事件，会造成相机控件的旋转、缩放等操作无效，也有可能会影响你的射线拾取,等等任何与canvas画布有关的鼠标事件都有可能收到影响，不过这算是普
阅读更多2024-11-17
Scala-字符串（拼接、printf格式化输出等）-用法详解
Scala-字符串（拼接、printf格式化输出等）用法
阅读更多2024-11-17
c++原型模式（Prototype Pattern）
每个原型类实现自己的克隆方法，从而确保了对象的正确复制。
阅读更多2024-11-17
问题大集-01-kafka问题
1、Windows下启动单机kafka出现：系统找不到指定路径解决：是kafka不能识别本机的java环境（JVM），故需要指定java路径，进入kafka路径下的\bin\windows，找到：ka
阅读更多2024-11-17
【点云上采样】最近邻插值上采样算法增加点云密度
传感器采集到的点云比较稀疏，毕竟价位在那，好的太贵，买便宜的点又太稀，需要增加点云数据。
阅读更多2024-11-17
阮一峰科技爱好者周刊（第 325 期）推荐工具：一个基于 Next.js 的博客和 CMS 系统
近期，阮一峰在科技爱好者周刊第 325 期中推荐了一款开源工具——ReactPress，ReactPress一个基于 Next.js 的博客和 CMS 系统，可查看 demo站点。（@fecommun
阅读更多2024-11-17
js识别二维码
将二维码转换为链接
阅读更多2024-11-17
C 语言【单链表】
‌数据域用于存储实际的数据，而指针域则存储指向下一个节点的地址。单链表的特点包括动态存储、非连续存储、易于插入和删除。节点可以定义成一个结构体，每个节点中包含一个数据和下一个节点的地址。上面的结构体定
阅读更多2024-11-17
校园求职招聘系统（程序+数据库+报告）
基于Spring Boot框架实现的校园求职招聘系统，系统包含两种角色：管理员、用户,系统分为前台和后台两大模块
阅读更多2024-11-17

Callable方式创建线程

方式一：

方式二：

相关文章