码迷,mamicode.com
首页 > 编程语言 > 详细

Java再学习——线程之创建

时间:2015-11-08 14:17:28      阅读:257      评论:0      收藏:0      [点我收藏+]

标签:

Java创建线程有两种方法,一种是继承Thread,另一种实现Runnable或Callable接口。

一,继承Thread

public class APP {

    public static void main(String[] args) {
        Thread thread = new Thread() {
            @Override
            public void run() {
                int i = 0;
                while (i < 100) {
                    System.out.println(i++);
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        };
        thread.start();
    }
}

上述例子通过重写Thread的run方法,来定时输出i的值,但是要主要Thread的run方法仅仅是个普通的方法,必须要通过调用start方法才能创建线程去执行run方法,直接调用run就没有线程的创建了。

 

二,实现Runnable或Callable接口来创建线程。

这两个接口的实现只能是变成一个普通的类,要创建线程都必须要通过其他相关类开启的。

这两个接口最大的区别:Callable有返回值且能抛出受检测异常,而Runnable没有返回值也无法抛出受检测异常;

 

1,对于Runnable接口来说,

  要通过它来创建线程的的方法有两种,一种是通过Thread,另一种是通过Executor

public class APP {

    public static void main(String[] args) {

        class MyRunnable implements Runnable {
            @Override
            public void run() {
                System.out.println("start -> "
                        + Thread.currentThread().getName());
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("end -> " + Thread.currentThread().getName());
            }

        }

        Thread thread = new Thread(new MyRunnable());
        thread.start();

        Executor executor = Executors.newSingleThreadExecutor();
        executor.execute(new MyRunnable());
    }
}

 

2,对于Callable接口来说,

  要通过它来创建线程的的方法有两种,一种是通过Thread,另一种是通过ExecutorService,但是都要同时借助于Future接口来实现对Callable返回值的相关控制。这里的ExecutorService接口是继承了Executor接口的,它增加了一些功能,大家可以点开源码看看就知道,而实例化都是通过Executors类的静态方法来实现的。

2.1 通过Thread去创建

  由于Thread只能接受Runnable所以要想通过Thread去创建Callable线程,还要再借助一个即继承了Callable接口也继承了Runnable接口的类,这个类就是FutureTask。

2.2 通过ExecutorService去创建

  由于ExecutorService天然支持Callable接口,所以直接submit就可以了。

public class APP {

    public static void main(String[] args) throws Exception {

        class MyCallable implements Callable<Integer> {
            @Override
            public Integer call() throws Exception {
                Thread.sleep(3000);
                System.out.println("end");
                return 200;
            }
        }

        ExecutorService es = Executors.newCachedThreadPool();
        Future<Integer> future = es.submit(new MyCallable());
        System.out.println("when ExecutorService -> " + future.get());

        FutureTask<Integer> task = new FutureTask<Integer>(new MyCallable());
        Thread thread = new Thread(task);
        thread.start();
        System.out.println("when Thread ->" + task.get());
    }
}

备注:

Future的get方法是线程阻塞的,直到Callable的call()方法返回值为止。

再次提醒创建线程不要直接调用run方法。

如果发现理解不了,最好点进去看看源码。

 

Java再学习——线程之创建

标签:

原文地址:http://www.cnblogs.com/wytings/p/4946682.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!