java 线程

本贴最后更新于 1919 天前,其中的信息可能已经天翻地覆

前言

进程:内存运行的程序。

线程:进程中的一个执行单元。

创建多线程的方式

本质都是调用自己写的 run 方法。

1 继承 thread 抽象类

Thread thread = new Thread(){
    @Override
    public void run() {
        for(int i=0;i<10;i++){
            System.out.println("线程创建的第一种方式:"+Thread.currentThread().getName());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
};
thread.start();

2 实现 Runnable 接口

Thread thread2 = new Thread(new Runnable() {
    @Override
    public void run() {
        for(int i=0;i<10;i++){
            System.out.println("线程创建的第二种方式:"+Thread.currentThread().getName());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
});
thread2.start();

3 实现 Callable 接口

FuttureTask 继承 RunnableFuture,
RunnableFuture 继承 runnable 和 future。

FutureTask<Integer> ft = new FutureTask<Integer>(new Callable<Integer>() {
    @Override
    public Integer call() throws Exception {
        int i = 0;
        for(;i<10;i++){
            System.out.println("线程创建的第三种方式:"+Thread.currentThread().getName());
        }
        return i;
    }
});
new Thread(ft).start();

匿名内部类

改进实现 runnable 接口的形式

jdk8 lambda 简写:

new Thread(()->{
            System.out.println(123);
        }).start();

完整版

new Thread(new Runnable() {
            @Override
            public void run() {
                for (int i = 0; i < 10000; i++) {
                    System.out.println(Thread.currentThread().getName() + i);
                }
            }
        }).start();

线程池

  • Executors 创建线程池

阿里巴巴不推荐

ExecutorService service = Executors.newFixedThreadPool(2);
service.submit(new Runnable() {
    @Override
    public void run() {
        System.out.println("新线程执行");
    }
});
有什么线程池?
new SingleThreadExecutor:创建一个单线程的线程池
new FixedThreadPool:创建固定大小的线程池
new CachedThreadPool:创建一个可缓存的线程池,最大空闲时间默认为1分钟,超过就会被删除。
new ScheduledThreadPool:创建一个大小无限的线程池,可以延迟、定时循环执行任务。
  • 线程池启动策略
ThreadPoolExecutor executor = new ThreadPoolExecutor(10,
        20,
        60L,
        TimeUnit.SECONDS,
        new SynchronousQueue<Runnable>(),
        Executors.defaultThreadFactory(),
        new ThreadPoolExecutor.AbortPolicy()
);
线程池创建

添加任务时:
如果当前线程数量小于corePoolSize,则马上创建线程运行任务。

如果大于等于core Pool Size,任务放入队列。

如果队列满了,线程总数小于最大值,创建线程运行任务。

如何,线程总数等于,则报错。

线程安全

多个线程同时对一个数据进行写操作,会出现安全问题。

同步代码块

所有线程都要使用同一把锁,比如: ""

synchronized(同步锁){
    # 需要同步操作的代码
}
# 强制处于waiting状态
同步锁.waiting();

# 唤醒处于waiting状态的线程来抢锁:
同步锁.notify();

同步方法

对于非 static 方法,同步锁就是 this。
对于 static 方法,我们使用当前方法所在类的字节码对象(类名.class)

public synchronized void method(){
可能会产生线程安全问题的代码
}

锁机制

同理:一定要使用同一把锁!!!

Lock lock = new ReentrantLock();
ExecutorService service = Executors.newFixedThreadPool(2);
service.submit(new Runnable() {
    @Override
    public void run() {
        lock.lock();
        System.out.println(123);
        lock.unlock();
    }
});

线程状态

  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3165 引用 • 8206 回帖 • 1 关注

相关帖子

回帖

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...