目录
进程:内存运行的程序。
线程:进程中的一个执行单元。
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();
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();
}
});
原文:https://www.cnblogs.com/birdofparadise/p/9769286.html