java中多线程实现方式

2021-02-16 21:19

阅读：663

标签：nbsp name 自己实现需要介绍主线程 c中 str inf

　　java中线程是经常会提到的问题，但是实际开发工作却又很少用的技术（起码本人用的比较少）。下面介绍几种常见的线程实现方式

　　1、继承Thread类，重写run方法

　　　我们通过集成Thread类并通过重写run方法的方式实现线程，然后通过start方法启动线程

public class MyThread extends Thread{

    @Override
    public void run() {
        System.out.println("================"+new Date());
    }

    public static void main(String[] args) {
        for(int i=0;i){
            MyThread myThread = new MyThread();
            myThread.start();
        }
    }
}

运行main方法测试效果：

技术图片

　　2、通过实现Runable接口的方式

　　Thread作为java中的线程类，其有一个Runable作为构造参数的构造方法，我们可以通过实现Runable接口，从而进一步实现线程。同样是通过start启动线程。

/**
 * 通过实现Runable接口
 */
public class MyRunableImpl implements Runnable{

    private String name;

    public MyRunableImpl(String name) {
        this.name = name;
    }

    @Override
    public void run() {
        System.out.println(name+"================"+new Date());
    }

    public static void main(String[] args) {
        for(int i=0;i){
            MyRunableImpl myRunable = new MyRunableImpl("myRunable"+i);
            Thread t = new Thread(myRunable);
            t.start();
        }
    }
}

运行main方法测试效果：

技术图片

　　3、通过FutureTask实现线程

　　此方式和第二种方式有点像，还是使用Thread(Runnable)构造方法，区别在于此处不用自己实现Runable,而是使用FutureTask。FutureTask实现了

RunnableFuture接口，而RunnableFuture接口又集成了Runable接口，所以我们也可以使用FutureTask做为构造参数创建线程。FutureTask支持两种有参的构造方法，此处我们使用Future(Callable)。首先，我们需要创建一个类，该类需要实现Callable接口，实现call方法。

public class MyCallable implements Callable {

    private String name;

    public MyCallable(String name) {
        this.name = name;
    }

    @Override
    public Object call() throws Exception {
        System.out.println(name+"==============="+new Date());
        return name;
    }
}

测试类

public class FutureTaskTest {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        for(int i=0;i){
            MyCallable myCallable = new MyCallable("myCallable"+i);
            FutureTask futureTask = new FutureTask(myCallable);
            Thread t = new Thread(futureTask);
            t.start();
            Object o = futureTask.get();
            System.out.println("return value============"+o);
        }
    }
}

运行main方法测试效果：

技术图片

在线程启动时会调用Callable接口的call方法。我们可以通过FutureTask.get()方法获取call()的返回值。需要注意的是get方法会阻塞线程。

　　4、使用Executors创建线程池

　　Executors是java juc中的类，我们可以通过其创建线程池，并以此实现线程。此方式同样需要一个Callable的实现类，此处我们还是使用第3中方法中的类。

public class ExecutorsTest {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        List> list = new ArrayList();
        for(int i=0;i){
            MyCallable myCallable = new MyCallable("myCallable"+i);
            Future submit = executorService.submit(myCallable);
            list.add(submit);
        }
        for(Future future:list){
            try {
                Object o = future.get();
                System.out.println("return value============="+o);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
        executorService.shutdown();
    }
}

我们通过Executors创建线程池，ExecutorService.submit(Callable)启动线程。submit方法会返回一个Future对象，通过其get()方法可以获取Callable实现类的call方法返回值。执行完上述操作后需要调用ExecutorService.shutdown方法，不然主线程会一直处于运行状态。

执行main方法测试效果：

技术图片

以上就是常见的创建多线程的几种方式。如果不对，对应大家评论留言。

java中多线程实现方式

标签：nbsp name 自己实现需要介绍主线程 c中 str inf

原文地址：https://www.cnblogs.com/xiupan/p/12702267.html

上一篇：[Java] 分布式消息队列（MQ）

下一篇：C++ 写出这个数

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：java中多线程实现方式
文章链接：http://soscw.com/index.php/essay/56265.html

亲，登录后才可以留言！

java中多线程实现方式

评论

热门文章

推荐文章

最新文章

置顶文章