文档章节

Java多线程实现(四种方法)

o
 osc_4nmshwhm
发布于 2018/08/06 23:33
字数 837
阅读 14
收藏 0

 

1.继承Thread类,重写run方法(其实Thread类本身也实现了Runnable接口)

2.实现Runnable接口,重写run方法

3.实现Callable接口,重写call方法(有返回值)

4.使用线程池(有返回值)

 

1.继承Thread类,重写run方法

  每次创建一个新的线程,都要新建一个Thread子类的对象

  启动线程,new Thread子类().start()

  创建线程实际调用的是父类Thread空参的构造器

public class MyThread {

    public static void main(String ards[]){
        for(int i=0;i<10;i++){
            new ExtendsThread().start();
        }
        System.out.println(Thread.currentThread().getName());
    }
    
}

class ExtendsThread extends Thread{ @Override public void run() { System.out.println(Thread.currentThread().getName()); } }

 

2.实现Runnable接口,重写run方法

  不论创建多少个线程,只需要创建一个Runnable接口实现类的对象

  启动线程,new Thread(Runnable接口实现类的对象).start()

   创建线程调用的是Thread类Runable类型参数的构造器

public class MyThread {

    public static void main(String ards[]){
        Runnable implRunnable = new ImplRunnable();
        for(int i=0;i<10;i++){
            new Thread(implRunnable).start(); } System.out.println(Thread.currentThread().getName()); } } class ImplRunnable implements Runnable{ private volatile int i = 0; @Override public void run() { System.out.println(Thread.currentThread().getName()+"--"+ i++); } }

 

3.实现Callable接口,重写call方法(有返回值)

  自定义类实现Callable接口时,必须指定泛型,该泛型即返回值的类型

  每次创建一个新的线程,都要创建一个新的Callable接口的实现类、

  如何启动线程?

    (1)创建一个Callable接口的实现类的对象

    (2)创建一个FutureTask对象,传入Callable类型的参数

        public FutureTask(Callable<V> callable){……}

    (3)调用Thread类重载的参数为Runnable的构造器创建Thread对象

        将FutureTask作为参数传递

        public class FutureTask<V> implements RunnableFuture<V>

        public interface RunnableFuture<V> extends Runnable, Future<V>

  如何获取返回值?

    调用FutureTask类的get()方法

public class MyThread {

    public static void main(String ards[]) throws InterruptedException, ExecutionException{

        for(int i=0;i<10;i++){
            Callable<Integer> implCallable = new ImplCallable();
            FutureTask<Integer> futureTask = new FutureTask<Integer>(implCallable); new Thread(futureTask).start(); System.out.println(Thread.currentThread().getName()+"----"+futureTask.get()); } System.out.println(Thread.currentThread().getName()); } } class ImplCallable implements Callable<Integer>{ @Override public Integer call() throws Exception { int result = 0; for(int i=0;i<10;i++){ result += i; } System.out.println(Thread.currentThread().getName()); return result; } }

 

4.线程池

Executors类

 

/**
 *
 * 线程池
 * 跟数据库连接池类似
 * 避免了线程的创建和销毁造成的额外开销
 *
 * java.util.concurrent
 *
 * Executor    负责现成的使用和调度的根接口
 *    |--ExecutorService    线程池的主要接口
 *          |--ThreadPoolExecutor    线程池的实现类
 *          |--ScheduledExecutorService    接口,负责线程的调度
 *              |--ScheduledThreadPoolExecutor    (extends ThreadPoolExecutor implements ScheduledExecutorService)
 *
 *
 * Executors工具类
 * 提供了创建线程池的方法
 *
 */
public class ThreadPool {
    public static void main(String[] args){

        //使用Executors工具类中的方法创建线程池
        ExecutorService pool = Executors.newFixedThreadPool(5);

        ThreadPoolDemo demo = new ThreadPoolDemo();

        //为线程池中的线程分配任务,使用submit方法,传入的参数可以是Runnable的实现类,也可以是Callable的实现类
        for(int i=1;i<=5;i++){
            pool.submit(demo);
        }

        //关闭线程池
        //shutdown : 以一种平和的方式关闭线程池,在关闭线程池之前,会等待线程池中的所有的任务都结束,不在接受新任务
        //shutdownNow : 立即关闭线程池
        pool.shutdown();


    }
}
class ThreadPoolDemo implements Runnable{

    /**多线程的共享数据*/
    private int i = 0;

    @Override
    public void run() {
        while(i<=50){
            System.out.println(Thread.currentThread().getName()+"---"+ i++);
        }
    }
}

 

 

public class ThreadPool2 {
    
    public static void main(String args[]){
        ExecutorService executorService = Executors.newFixedThreadPool(5);
        
        for(int i=0;i<5;i++){
            Future<Integer> future = executorService.submit(new Callable<Integer>() {

                @Override
                public Integer call() throws Exception {
                    int result = 0;
                    for(int i=0;i<=10;i++){
                        result += i;
                    }
                    return result;
                }
            });
            
            try {
                System.out.println(Thread.currentThread().getName()+"--"+future.get());
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }
        
        executorService.shutdown();

    }

}

 

o
粉丝 0
博文 500
码字总数 0
作品 0
私信 提问
加载中
请先登录后再评论。

暂无文章

李开复谈2020年AI科学家创业。道翰天琼认知智能api机器人接口。

2012年至今,在深度学习推动下,这一波人工智能的蓬勃发展已进入第十个年头。 在初期,一系列由AI科学家创建的初创公司,经过大浪淘沙,如今已有多家脱颖而出成为独角兽企业;榜样在先,于是...

jackli2020
22分钟前
9
0
什么是PHP中的线程安全或非线程安全? - What is thread safe or non-thread safe in PHP?

问题: I saw different binaries for PHP, like non-thread or thread safe? 我看到了PHP的不同二进制文件,例如非线程还是线程安全的? What does this mean? 这是什么意思? What is the ...

fyin1314
36分钟前
26
0
移动社交如何玩?网易云信携手崽崽和Uki打造更多新场景!

随着95后、00后为主的年轻一代逐渐成为中国移动社交下的主力军,社交需求也发生了一些变化。这些年轻用户更倾向于有趣好玩,形式多样化的社交方式。同时也产生了如“扩列”、“养火花”等众多...

真正稳定的网易云信
42分钟前
22
0
如何在Java代码中去掉烦人的“!=null”

问题 为了避免空指针调用,我们经常会看到这样的语句 if (someobject != null) { someobject.doCalc();} 最终,项目中会存在大量判空代码,多么丑陋繁冗!如何避免这种情况?我们是否滥...

码农突围
43分钟前
21
0
ELK使用容器集成安装

ELK使用容器集成安装 1. 查看集成ELK:sebp docker search sebp 2. 设置内核参数 sysctl -w vm.max_map_count=262144 3. 拉取sebp/elk docker pull sebp/elk 4. 运行ELK yum install -y java......

huanke
53分钟前
17
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部