Java多线程实现方式

1.继承Thread类创建线程

线程类

public class MyThread extends Thread {
    @Override
    public void run() {
        for (int i = 0; i <= 10; i++) {
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(i);
        }
    }
}

测试代码

MyThread thread=new MyThread();
thread.start();
System.out.println("123");

2.实现Runable接口创建线程

线程类

public class MyRunable implements Runnable {
    @Override
    public void run() {
        for (int i = 0; i <= 10; i++) {
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(i);
        }
    }
}

测试代码

Thread runable=new Thread(new MyRunable());
runable.start();
System.out.println("456");

3.使用线程池实现多线程

ExecutorService、Callable、Future对象都是属于Executor框架中的功能类
Executors类,提供工厂方法用于创建线程池,返回的线程池都实现了ExecutorService接口
创建有返回值的线程 必须实现Callable<V>接口,无返回值的实现Runable接口

// 创建固定数目线程的线程池
ExecutorService executorService = Executors.newFixedThreadPool(int poolSize);
// 创建一个可缓存的线程池
ExecutorService executorService = Executors.newCachedThreadPool();
// 创建一个单线程化的线程池
ExecutorService executorService = Executors.newSingleThreadExecutor();
// 创建一个支持定时及周期性的任务执行的线程池
ExecutorService executorService = Executors.newScheduledThreadPool(int corePoolSize);

线程类

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
public class MyExecutorCallable implements Callable<Object> {
    private List<String> names;
    public MyExecutorCallable() {
    }
    @Override
    public Object call() throws Exception {
        names = new ArrayList<>();
        for (int i = 0; i <= 5; i++) {
            names.add("Name" + i + "\n");
        }
        return names;
    }
}

测试代码

// 创建固定数目线程线的程池
ExecutorService executorService = Executors.newFixedThreadPool(10);
// 创建多个有返回值的任务
List<Future> futures = new ArrayList<>();
for (int i = 0; i < 5; i++) {
    Callable callable = new MyExecutorCallable ();
    // 执行任务并获取返回值
    Future future = executorService.submit(callable);
    futures.add(future);
}
// 关闭线程池
executorService.shutdown();
// 输出返回值
for (Future future : futures) {
    System.out.println(future.get().toString() + "\n");
}
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 包含三种方式: (1)继承Thread类,重写run函数 创建: class xx extends Thread{...
    元气满满小酒窝阅读 2,271评论 0 1
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 32,171评论 18 399
  • 个人笔记,方便自己查阅使用 Contents Java LangAssignment, ReferenceData...
    freenik阅读 5,234评论 0 6
  • 如果不正确的去安慰一个人,会造成以下危害: 1-会让倾诉者对倾诉失去兴趣,会害怕自身误会,害怕评判,害怕自以为是的...
    end木阅读 2,839评论 0 0
  • 我只能是自己世界里的佼佼者(1) 我发现我越来越在意第一、第二这样的字眼。我开始不顾一切要成为那个第一,唯一的第一...
    蘑菇小姐Elise阅读 2,880评论 0 0