em,据说多线程是面试的重点。第一次学习的时候,只是粗略的看了一下,不少概念并非很清楚。此次整理一下,省得白学java
进程面试
线程缓存
分时调度安全
抢占式调度多线程
同步: 排队执行 , 效率低可是安全.
异步: 同时执行 , 效率高可是数据不安全.并发
并发:指两个或多个事件在同一个时间段内发生。
并行:指两个或多个事件在同一时刻发生(同时发生)。异步
继承Thread类:ide
public class ThreadDemo extends Thread{ public ThreadDemo(String name) { super(name); } @Override public void run() { System.out.println(Thread.currentThread().getName() + " Hello"); } public static void main(String[] args) { new ThreadDemo("自定义线程").start(); System.out.println(Thread.currentThread().getName() + " Hello"); } }
实现Runnable接口学习
public class RunnableDemo implements Runnable{ @Override public void run() { System.out.println(Thread.currentThread().getName() + " Hello"); } public static void main(String[] args) { new Thread(new RunnableDemo(), "自定义线程").start(); System.out.println(Thread.currentThread().getName() + " Hello"); } }
实现Runnable 与 集成Thread相比有以下优点:线程
- 经过建立任务,给线程分配任务实现多线程,更适合多线程同时执行相同的任务状况
2. 避免单继承带来的局限性
3. 任务与线程自己是分离的,提升了程序的健壮性
4. 后续学习的线程技术,只接受Runnable类型的任务,不接受Thread类型的线程
当多个线程操做同一个数据的时候会出现线程安全问题
public class Demo04 { /** * 线程安全问题 * * @param args */ private static int count = 100; public static void main(String[] args) { Runnable runnable = new Runnable() { @Override public void run() { while (count > 0) { System.out.println(Thread.currentThread().getName() + ":" + "当前票数为:" + count); count--; System.out.println(Thread.currentThread().getName() + ":" + "当前票数为:" + count); } } }; new Thread(runnable, "线程一").start(); new Thread(runnable, "线程二").start(); new Thread(runnable, "线程三").start(); new Thread(runnable, "线程四").start(); } }
线程二:当前票数为:100
线程三:当前票数为:100
线程三:当前票数为:98
线程一:当前票数为:100
线程一:当前票数为:97
...
线程三:当前票数为:4
线程一:当前票数为:5
线程一:当前票数为:-2
线程三:当前票数为:-1
线程二:当前票数为:0
public class 同步代码块 { public static void main(String[] args) { Runnable runnable = new Runnable() { //隐式锁 //锁对象 private Object o = new Object(); private int count = 100; @Override public void run() { while (true) { synchronized (o) { if (count > 0) { System.out.println(Thread.currentThread().getName() + " count = " + count); count--; } else { break; } } } } }; new Thread(runnable, "线程一").start(); new Thread(runnable, "线程二").start(); new Thread(runnable, "线程三").start(); } }
public class 同步方法 { public static void main(String[] args) { Runnable runnable = new Runnable() { private int count = 100; @Override public void run() { while (true) { if (!reduce()){ break; } } } public synchronized boolean reduce() { if (count > 0) { System.out.println(Thread.currentThread().getName() + " count = " + count); count--; return true; } return false; } }; new Thread(runnable, "线程一").start(); new Thread(runnable, "线程二").start(); new Thread(runnable, "线程三").start(); } }
线程一 count = 100
线程一 count = 99
线程一 count = 98
线程一 count = 97
...
线程一 count = 87
线程一 count = 86
...
线程一 count = 4
线程一 count = 3
线程一 count = 2
线程一 count = 1
public class 显示锁 { /** * 显示锁: Lock 子类 ReentrantLock * * @param args */ public static void main(String[] args) { Runnable runnable = new Runnable() { private int count = 100; private Lock lock = new ReentrantLock(); @Override public void run() { while (true) { lock.lock(); if (count > 0) { System.out.println(Thread.currentThread().getName() + " count = " + count); count--; } else { break; } lock.unlock(); } System.out.println("bye"); } }; new Thread(runnable, "线程一").start(); new Thread(runnable, "线程二").start(); new Thread(runnable, "线程三").start(); } }
//接口定义 //Callable接口 public interface Callable<V> { V call() throws Exception; } //Runnable接口 public interface Runnable { public abstract void run(); }
若是并发的线程数量不少,而且每一个线程都是执行一个时间很短的任务就结束了,这样频繁建立线程 就会大大下降 系统的 效率,由于频繁建立线程和销毁线程须要时间. 线程池就是一个容纳多个线程的容 器,池中的线程能够反复使用,省去了频繁建立线程对象的操做,节省了大量的时间和资源。
线程池的好处
Java中的四种线程池 . ExecutorService
public class 缓存线程池 { /** * 缓存线程池. * (长度无限制) * 执行流程: * 1. 判断线程池是否存在空闲线程 * 2. 存在则使用 * 3. 不存在,则建立线程 并放入线程池, 而后使用 */ public static void main(String[] args) { ExecutorService service = Executors.newCachedThreadPool(); service.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + " Java"); } }); service.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + " Java"); } }); service.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + " Java"); } }); } }
pool-1-thread-1 Java
pool-1-thread-2 Java
pool-1-thread-2 Java
public class 定长线程池 { /** 定长线程池. * (长度是指定的数值) * 执行流程: * 1. 判断线程池是否存在空闲线程 * 2. 存在则使用 * 3. 不存在空闲线程,且线程池未满的状况下,则建立线程 并放入线程池, 而后使用 * 4. 不存在空闲线程,且线程池已满的状况下,则等待线程池存在空闲线程 */ public static void main(String[] args) { ExecutorService service = Executors.newFixedThreadPool(2); service.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + " Java"); } }); service.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + " Java"); } }); service.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + " Java"); } }); service.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + " Java"); } }); } }
pool-1-thread-1 Java
pool-1-thread-2 Java
pool-1-thread-1 Java
pool-1-thread-2 Java