java线程操作

Posted 2021-01-11 田云

目录

• 前言
• 创建多线程的方式
  • 继承thread抽象类
  • 实现Runnable接口
  • 匿名内部类
  • 线程池
• 线程安全
  • 同步代码块
  • 同步方法
  • 锁机制
• 线程状态

前言

进程：内存运行的程序。

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

创建多线程的方式

继承thread抽象类

• 创建

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

• 使用

new MyThread().start();

实现Runnable接口

• 实现

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

• 调用

new Thread(new MyRunnable()).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("新线程执行");
    }
});

线程安全

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

同步代码块

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

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();
    }
});

线程状态