摘要:無限期等待另一個線程執行特定操作。線程安全基本版請說明以及的區別值都不能為空數組結構上,通過數組和鏈表實現。優先考慮響應中斷,而不是響應鎖的普通獲取或重入獲取。只是在最后獲取鎖成功后再把當前線程置為狀態然后再中斷線程。
前段時間在慕課網直播上聽小馬哥面試勸退("面試虐我千百遍,Java 并發真討厭"),發現講得東西比自己拿到offer還要高興,于是自己在線下做了一點小筆記,供各位參考。
課程地址:https://www.bilibili.com/vide...
源碼文檔地址:https://github.com/mercyblitz...
本文來自于我的慕課網手記:小馬哥Java面試題課程總結,轉載請保留鏈接 ;)Java 多線程 1、線程創建 基本版
有哪些方法創建線程?
僅僅只有new thread這種方法創建線程
public class ThreadCreationQuestion { public static void main(String[] args) { // main 線程 -> 子線程 Thread thread = new Thread(() -> { }, "子線程-1"); } /** * 不鼓勵自定義(擴展) Thread */ private static class MyThread extends Thread { /** * 多態的方式,覆蓋父類實現 */ @Override public void run(){ super.run(); } } }
與運行線程方法區分:
java.lang.Runnable() 或 java.lang.Thread類
如何通過Java 創建進程?
public class ProcessCreationQuestion { public static void main(String[] args) throws IOException { // 獲取 Java Runtime Runtime runtime = Runtime.getRuntime(); Process process = runtime.exec("cmd /k start http://www.baidu.com"); process.exitValue(); } }勸退版
如何銷毀一個線程?
public class ThreadStateQuestion { public static void main(String[] args) { // main 線程 -> 子線程 Thread thread = new Thread(() -> { // new Runnable(){ public void run(){...}}; System.out.printf("線程[%s] 正在執行... ", Thread.currentThread().getName()); // 2 }, "子線程-1"); // 啟動線程 thread.start(); // 先于 Runnable 執行 System.out.printf("線程[%s] 是否還活著: %s ", thread.getName(), thread.isAlive()); // 1 // 在 Java 中,執行線程 Java 是沒有辦法銷毀它的, // 但是當 Thread.isAlive() 返回 false 時,實際底層的 Thread 已經被銷毀了 }
Java代碼中是無法實現的,只能表現一個線程的狀態。
而CPP是可以實現的。
2、線程執行 基本版如何通過 Java API 啟動線程?
thread.start();
進階版當有線程 T1、T2 以及 T3,如何實現T1 -> T2 -> T3的執行順序?
private static void threadJoinOneByOne() throws InterruptedException { Thread t1 = new Thread(ThreadExecutionQuestion::action, "t1"); Thread t2 = new Thread(ThreadExecutionQuestion::action, "t2"); Thread t3 = new Thread(ThreadExecutionQuestion::action, "t3"); // start() 僅是通知線程啟動 t1.start(); // join() 控制線程必須執行完成 t1.join(); t2.start(); t2.join(); t3.start(); t3.join(); } private static void action() { System.out.printf("線程[%s] 正在執行... ", Thread.currentThread().getName()); // 2 } }
CountDownLatch也可以實現;
調整優先級并不能保證優先級高的線程先執行。
勸退版以上問題請至少提供另外一種實現?(1.5)
1、spin 方法
private static void threadLoop() { Thread t1 = new Thread(ThreadExecutionQuestion::action, "t1"); Thread t2 = new Thread(ThreadExecutionQuestion::action, "t2"); Thread t3 = new Thread(ThreadExecutionQuestion::action, "t3"); t1.start(); while (t1.isAlive()) { // 自旋 Spin } t2.start(); while (t2.isAlive()) { } t3.start(); while (t3.isAlive()) { } }
2、sleep 方法
private static void threadSleep() throws InterruptedException { Thread t1 = new Thread(ThreadExecutionQuestion::action, "t1"); Thread t2 = new Thread(ThreadExecutionQuestion::action, "t2"); Thread t3 = new Thread(ThreadExecutionQuestion::action, "t3"); t1.start(); while (t1.isAlive()) { // sleep Thread.sleep(0); } t2.start(); while (t2.isAlive()) { Thread.sleep(0); } t3.start(); while (t3.isAlive()) { Thread.sleep(0); } }
3、while 方法
private static void threadWait() throws InterruptedException { Thread t1 = new Thread(ThreadExecutionQuestion::action, "t1"); Thread t2 = new Thread(ThreadExecutionQuestion::action, "t2"); Thread t3 = new Thread(ThreadExecutionQuestion::action, "t3"); threadStartAndWait(t1); threadStartAndWait(t2); threadStartAndWait(t3); } private static void threadStartAndWait(Thread thread) { if (Thread.State.NEW.equals(thread.getState())) { thread.start(); } while (thread.isAlive()) { synchronized (thread) { try { thread.wait(); // 到底是誰通知 Thread -> thread.notify(); JVM幫它喚起 // LockSupport.park(); // 死鎖發生 } catch (Exception e) { throw new RuntimeException(e); } } } }3、線程終止 基本版
如何停止一個線程?
public class HowToStopThreadQuestion { public static void main(String[] args) throws InterruptedException { Action action = new Action(); // 方法一 Thread t1 = new Thread(action, "t1"); t1.start(); // 改變 action stopped 狀態 action.setStopped(true); t1.join(); // 方法二 Thread t2 = new Thread(() -> { if (!Thread.currentThread().isInterrupted()) { action(); } }, "t2"); t2.start(); // 中斷操作(僅僅設置狀態,而并非中止線程) t2.interrupt(); t2.join(); } private static class Action implements Runnable { // 線程安全問題,確保可見性(Happens-Before) private volatile boolean stopped = false; @Override public void run() { if (!stopped) { // 執行動作 action(); } } public void setStopped(boolean stopped) { this.stopped = stopped; } } private static void action() { System.out.printf("線程[%s] 正在執行... ", Thread.currentThread().getName()); // 2 } }
想要停止一個線程是不可能的,真正的只能停止邏輯。
進階版為什么 Java 要放棄 Thread 的 stop()方法?
Because it is inherently unsafe. Stopping a thread causes it to unlock all the monitors that it has locked.(The monitors are unlocked as the ThreadDeath exception propagates up the stack.) If any of the objects previously protected by these monitors were in an inconsistent state, other threads may now view these objects in an inconsistent state. Such objects are said to be damaged. When threads operate on damaged objects, arbitrary behavior can result. This behavior may be subtle and difficult to detect, or it may be pronounced. Unlike other unchecked exceptions, ThreadDeath kills threads silently; thus, the user has no warning that his program may be corrupted. The corruption can manifest itself at any time after the actual damage occurs, even hours or days in the future.
Why is Thread.stop deprecated?
簡單的說,防止死鎖,以及狀態不一致的情況出現。
勸退版請說明 Thread interrupt()、isInterrupted() 以及 interrupted()的區別以及意義?
Thread interrupt(): 設置狀態,調JVM的本地(native)interrupt0()方法。
public void interrupt() { if (this != Thread.currentThread()) checkAccess(); synchronized (blockerLock) { Interruptible b = blocker; if (b != null) { interrupt0(); // Just to set the interrupt flag //--> private native void interrupt0(); b.interrupt(this); return; } } interrupt0(); }
isInterrupted(): 調的是靜態方法isInterrupted(),當且僅當狀態設置為中斷時,返回false,并不清除狀態。
public static boolean interrupted() { return currentThread().isInterrupted(true); } /** * Tests whether this thread has been interrupted. The interrupted * status of the thread is unaffected by this method. * *A thread interruption ignored because a thread was not alive * at the time of the interrupt will be reflected by this method * returning false. * * @return
true
if this thread has been interrupted; *false
otherwise. * @see #interrupted() * @revised 6.0 */ public boolean isInterrupted() { return isInterrupted(false); }
interrupted(): 私有本地方法,即判斷中斷狀態,又清除狀態。
private native boolean isInterrupted(boolean ClearInterrupted);4、線程異常 基本版
當線程遇到異常時,到底發生了什么?
線程會掛
public class ThreadExceptionQuestion { public static void main(String[] args) throws InterruptedException { //... // main 線程 -> 子線程 Thread t1 = new Thread(() -> { throw new RuntimeException("數據達到閾值"); }, "t1"); t1.start(); // main 線程會中止嗎? t1.join(); // Java Thread 是一個包裝,它由 GC 做垃圾回收 // JVM Thread 可能是一個 OS Thread,JVM 管理, // 當線程執行完畢(正常或者異常) System.out.println(t1.isAlive()); } }進階版
當線程遇到異常時,如何捕獲?
... Thread.setDefaultUncaughtExceptionHandler((thread, throwable) -> { System.out.printf("線程[%s] 遇到了異常,詳細信息:%s ", thread.getName(), throwable.getMessage()); }); ...勸退版
當線程遇到異常時,ThreadPoolExecutor 如何捕獲異常?
public class ThreadPoolExecutorExceptionQuestion { public static void main(String[] args) throws InterruptedException { // ExecutorService executorService = Executors.newFixedThreadPool(2); ThreadPoolExecutor executorService = new ThreadPoolExecutor( 1, 1, 0, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>() ) { /** * 通過覆蓋 {@link ThreadPoolExecutor#afterExecute(Runnable, Throwable)} 達到獲取異常的信息 * @param r * @param t */ @Override protected void afterExecute(Runnable r, Throwable t) { System.out.printf("線程[%s] 遇到了異常,詳細信息:%s ", Thread.currentThread().getName(), t.getMessage()); } }; executorService.execute(() -> { throw new RuntimeException("數據達到閾值"); }); // 等待一秒鐘,確保提交的任務完成 executorService.awaitTermination(1, TimeUnit.SECONDS); // 關閉線程池 executorService.shutdown(); } }5、線程狀態 基本版
Java 線程有哪些狀態,分別代表什么含義?
NEW: Thread state for a thread which has not yet started.
未啟動的。不會出現在Dump中。
RUNNABLE: Thread state for a runnable thread. A thread in the runnable state is executing in the Java virtual machine, but it may be waiting for other resources from the operating system such as processor.
在虛擬機內執行的。運行中狀態,可能里面還能看到locked字樣,表明它獲得了某把鎖。
BLOCKE: Thread state for a thread blocked waiting for a monitor lock. A thread in the blocked state is waiting for a monitor lock to enter a synchronized block/method or reenter a synchronized block/method after calling {@link Object#wait() Object.wait}.
受阻塞并等待監視器鎖。被某個鎖(synchronizers)給block住了。
WAITING: Thread state for a waiting thread. A thread is in the waiting state due to calling one of the following methods:
A thread in the waiting state is waiting for another thread to perform a particular action.
For example, a thread that has called Object.wait() on an object is waiting for another thread to call Object.notify() or Object.notifyAll() on that object. A thread that has called Thread.join() is waiting for a specified thread to terminate.
無限期等待另一個線程執行特定操作。等待某個condition或monitor發生,一般停留在park(), wait(), sleep(),join() 等語句里。
TIMED_WAITING: Thread state for a waiting thread with a specified waiting time. A thread is in the timed waiting state due to calling one of the following methods with a specified positive waiting time:
有時限的等待另一個線程的特定操作。和WAITING的區別是wait() 等語句加上了時間限制 wait(timeout)。
TERMINATED: 已退出的; Thread state for a terminated thread. The thread has completed execution.
進階版如何獲取當前JVM 所有的現場狀態?
方法一:命令
jstack: jstack用于打印出給定的java進程ID或core file或遠程調試服務的Java堆棧信息。主要用來查看Java線程的調用堆棧的,可以用來分析線程問題(如死鎖)。
jsp
jsp [option/ -l] pid
方法二:ThreadMXBean
public class AllThreadStackQuestion { public static void main(String[] args) { ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean(); long[] threadIds = threadMXBean.getAllThreadIds(); for (long threadId : threadIds) { ThreadInfo threadInfo = threadMXBean.getThreadInfo(threadId); System.out.println(threadInfo.toString()); } } }勸退版
如何獲取線程的資源消費情況?
public class AllThreadInfoQuestion { public static void main(String[] args) { ThreadMXBean threadMXBean = (ThreadMXBean) ManagementFactory.getThreadMXBean(); long[] threadIds = threadMXBean.getAllThreadIds(); for (long threadId : threadIds) { // ThreadInfo threadInfo = threadMXBean.getThreadInfo(threadId); // System.out.println(threadInfo.toString()); long bytes = threadMXBean.getThreadAllocatedBytes(threadId); long kBytes = bytes / 1024; System.out.printf("線程[ID:%d] 分配內存: %s KB ", threadId, kBytes); } } }6、線程同步 基本版
請說明 synchronized 關鍵字在修飾方法與代碼塊中的區別?
字節碼的區別 (一個monitor,一個synchronized關鍵字)
public class SynchronizedKeywordQuestion { public static void main(String[] args) { } private static void synchronizedBlock() { synchronized (SynchronizedKeywordQuestion.class) { } } private synchronized static void synchronizedMethod() { } }進階版
請說明 synchronized 關鍵字與 ReentrantLock 之間的區別?
兩者都是可重入鎖
synchronized 依賴于 JVM 而 ReentrantLock 依賴于 API
ReentrantLock 比 synchronized 增加了一些高級功能
相比synchronized,ReentrantLock增加了一些高級功能。主要來說主要有三點:①等待可中斷;②可實現公平鎖;③可實現選擇性通知(鎖可以綁定多個條件)
兩者的性能已經相差無幾
談談 synchronized 和 ReentrantLock 的區別
勸退版請解釋偏向鎖對 synchronized 與 ReentrantLock 的價值?
偏向鎖只對 synchronized 有用,而 ReentrantLock 已經實現了偏向鎖。
Synchronization and Object Locking
7、線程通訊 基本版為什么 wait() 和 notify() 以及 notifyAll() 方法屬于 Object ,并解釋它們的作用?
Java所有對象都是來自 Object
wait():
notify():
notifyAll():
進階版為什么 Object wait() notify() 以及 notifyAll() 方法必須 synchronized 之中執行?
wait(): 獲得鎖的對象,釋放鎖,當前線程又被阻塞,等同于Java 5 LockSupport 中的park方法
notify(): 已經獲得鎖,喚起一個被阻塞的線程,等同于Java 5 LockSupport 中的unpark()方法
notifyAll():
勸退版請通過 Java 代碼模擬實現 wait() 和 notify() 以及 notifyAll() 的語義?
8、線程退出 基本版當主線程退出時,守護線程會執行完畢嗎?
不一定執行完畢
public class DaemonThreadQuestion { public static void main(String[] args) { // main 線程 Thread t1 = new Thread(() -> { System.out.println("Hello,World"); // Thread currentThread = Thread.currentThread(); // System.out.printf("線程[name : %s, daemon:%s]: Hello,World ", // currentThread.getName(), // currentThread.isDaemon() // ); }, "daemon"); // 編程守候線程 t1.setDaemon(true); t1.start(); // 守候線程的執行依賴于執行時間(非唯一評判) } }進階版
請說明 ShutdownHook 線程的使用場景,以及如何觸發執行?
public class ShutdownHookQuestion { public static void main(String[] args) { Runtime runtime = Runtime.getRuntime(); runtime.addShutdownHook(new Thread(ShutdownHookQuestion::action, "Shutdown Hook Question")); } private static void action() { System.out.printf("線程[%s] 正在執行... ", Thread.currentThread().getName()); // 2 } }
使用場景:Spring 中 AbstractApplicationContext 的 registerShutdownHook()
勸退版如何確保主線程退出前,所有線程執行完畢?
public class CompleteAllThreadsQuestion { public static void main(String[] args) throws InterruptedException { // main 線程 -> 子線程 Thread t1 = new Thread(CompleteAllThreadsQuestion::action, "t1"); Thread t2 = new Thread(CompleteAllThreadsQuestion::action, "t2"); Thread t3 = new Thread(CompleteAllThreadsQuestion::action, "t3"); // 不確定 t1、t2、t3 是否調用 start() t1.start(); t2.start(); t3.start(); // 創建了 N Thread Thread mainThread = Thread.currentThread(); // 獲取 main 線程組 ThreadGroup threadGroup = mainThread.getThreadGroup(); // 活躍的線程數 int count = threadGroup.activeCount(); Thread[] threads = new Thread[count]; // 把所有的線程復制 threads 數組 threadGroup.enumerate(threads, true); for (Thread thread : threads) { System.out.printf("當前活躍線程: %s ", thread.getName()); } } private static void action() { System.out.printf("線程[%s] 正在執行... ", Thread.currentThread().getName()); // 2 } }Java 并發集合框架 1、線程安全集合 基本版
請在 Java 集合框架以及 J.U.C 框架中各列舉出 List、Set 以及 Map 的實現?
Java 集合框架: LinkedList、ArrayList、HashSet、TreeSet、HashMap
J.U.C 框架: CopyOnWriteArrayList、CopyOnWriteArraySet、ConcurrentSkipListSet、ConcurrentSkipListMap、ConcurrentHashMap
進階版如何將普通 List、Set 以及 Map 轉化為線程安全對象?
public class ThreadSafeCollectionQuestion { public static void main(String[] args) { List勸退版list = Arrays.asList(1, 2, 3, 4, 5); Set set = Set.of(1, 2, 3, 4, 5); Map map = Map.of(1, "A"); // 以上實現都是不變對象,不過第一個除外 // 通過 Collections#sychronized* 方法返回 // Wrapper 設計模式(所有的方法都被 synchronized 同步或互斥) list = Collections.synchronizedList(list); set = Collections.synchronizedSet(set); map = Collections.synchronizedMap(map); } }
如何在 Java 9+ 實現以上問題?
public class ThreadSafeCollectionQuestion { public static void main(String[] args) { // Java 9 的實現 List2、線程安全 LIST 基本版list = Arrays.asList(1, 2, 3, 4, 5); // Java 9 + of 工廠方法,返回 Immutable 對象 list = List.of(1, 2, 3, 4, 5); Set set = Set.of(1, 2, 3, 4, 5); Map map = Map.of(1, "A"); // 以上實現都是不變對象,不過第一個除外 // 通過 Collections#sychronized* 方法返回 // Wrapper 設計模式(所有的方法都被 synchronized 同步或互斥) list = Collections.synchronizedList(list); set = Collections.synchronizedSet(set); map = Collections.synchronizedMap(map); // list = new CopyOnWriteArrayList<>(list); set = new CopyOnWriteArraySet<>(set); map = new ConcurrentHashMap<>(map); } }
請說明 List、Vector 以及 CopyOnWriteArrayList 的相同點和不同點?
相同點:
Vector、CopyOnWriteArrayList 是 List 的實現。
不同點:
Vector 是同步的,任何時候不加鎖。并且在設計中有個 interator ,返回的對象是 fail-fast;
CopyOnWriteArrayList 讀的時候是不加鎖;弱一致性,while true的時候不報錯。
進階版請說明 Collections#synchromizedList(List) 與 Vector 的相同點和不同點?
相同點:
都是synchromized 的實現方式。
不同點:
synchromized 返回的是list, 實現原理方式是 Wrapper 實現;
而 Vector 是 List 的實現。實現原理方式是非 Wrapper 實現。
勸退版Arrays#asList(Object...)方法是線程安全的嗎?如果不是的話,如果實現替代方案?
public class ArraysAsListMethodQuestion { public static void main(String[] args) { List3、線程安全 SET 基本版list = Arrays.asList(1, 2, 3, 4, 5); // 調整第三個元素為 9 list.set(2, 9); // 3 -> 9 // Arrays.asList 并非線程安全 list.forEach(System.out::println); // Java < 5 , Collections#synchronizedList // Java 5+ , CopyOnWriteArrayList // Java 9+ , List.of(...) 只讀 } }
請至少舉出三種線程安全的 Set 實現?
synchronizedSet、CopyOnWriteArraySet、ConcurrentSkipListSet
進階版在 J.U.C 框架中,存在HashSet 的線程安全實現?如果不存在的話,要如何實現?
不存在;
public class ConcurrentHashSetQuestion { public static void main(String[] args) { } private static class ConcurrentHashSet勸退版implements Set { private final Object OBJECT = new Object(); private final ConcurrentHashMap map = new ConcurrentHashMap<>(); private Set keySet() { return map.keySet(); } @Override public int size() { return keySet().size(); } @Override public boolean isEmpty() { return keySet().isEmpty(); } @Override public boolean contains(Object o) { return keySet().contains(o); } @Override public Iterator iterator() { return keySet().iterator(); } @Override public Object[] toArray() { return new Object[0]; } @Override public T[] toArray(T[] a) { return null; } @Override public boolean add(E e) { return map.put(e, OBJECT) == null; } @Override public boolean remove(Object o) { return map.remove(o) != null; } @Override public boolean containsAll(Collection> c) { return false; } @Override public boolean addAll(Collection extends E> c) { return false; } @Override public boolean retainAll(Collection> c) { return false; } @Override public boolean removeAll(Collection> c) { return false; } @Override public void clear() { } } }
當 Set#iterator() 方法返回 Iterator 對象后,能否在其迭代中,給 Set 對象添加新的元素?
不一定;Set 在傳統實現中,會有fail-fast問題;而在J.U.C中會出現弱一致性,對數據的一致性要求較低,是可以給 Set 對象添加新的元素。
4、線程安全 MAP 基本版請說明 Hashtable、HashMap 以及 ConcurrentHashMap 的區別?
Hashtable: key、value值都不能為空; 數組結構上,通過數組和鏈表實現。
HashMap: key、value值都能為空;數組結構上,當閾值到達8時,通過紅黑樹實現。
ConcurrentHashMap: key、value值都不能為空;數組結構上,當閾值到達8時,通過紅黑樹實現。
HashMap和Hashtable的比較
進階版請說明 ConcurrentHashMap 在不同的JDK 中的實現?
JDK 1.6中,采用分離鎖的方式,在讀的時候,部分鎖;寫的時候,完全鎖。而在JDK 1.7、1.8中,讀的時候不需要鎖的,寫的時候需要鎖的。并且JDK 1.8中在為了解決Hash沖突,采用紅黑樹解決。
HashMap? ConcurrentHashMap? 相信看完這篇沒人能難住你!
勸退版請說明 ConcurrentHashMap 與 ConcurrentSkipListMap 各自的優勢與不足?
在 java 6 和 8 中,ConcurrentHashMap 寫的時候,是加鎖的,所以內存占得比較小,而 ConcurrentSkipListMap 寫的時候是不加鎖的,內存占得相對比較大,通過空間換取時間上的成本,速度較快,但比前者要慢,ConcurrentHashMap 基本上是常量時間。ConcurrentSkipListMap 讀和寫都是log N實現,高性能相對穩定。
5、線程安全 QUEUE 基本版請說明 BlockingQueue 與 Queue 的區別?
BlockingQueue 繼承了 Queue 的實現;put 方法中有個阻塞的操作(InterruptedException),當隊列滿的時候,put 會被阻塞;當隊列空的時候,put方法可用。take 方法中,當數據存在時,才可以返回,否則為空。
進階版請說明 LinkedBlockingQueue 與 ArrayBlockingQueue 的區別?
LinkedBlockingQueue 是鏈表結構;有兩個構造器,一個是(Integer.MAX_VALUE),無邊界,另一個是(int capacity),有邊界;ArrayBlockingQueue 是數組結構;有邊界。
勸退版請說明 LinkedTransferQueue 與 LinkedBlockingQueue 的區別?
LinkedTransferQueue 是java 7中提供的新接口,性能比后者更優化。
6、PRIORITYBLOCKINGQUEUE 請評估以下程序的運行結果?public class priorityBlockingQueueQuiz{ public static void main(String[] args) throw Exception { BlockingQueuequeue = new PriorityBlockingQueue<>(2); // 1. PriorityBlockingQueue put(Object) 方法不阻塞,不拋異常 // 2. PriorityBlockingQueue offer(Object) 方法不限制,允許長度變長 // 3. PriorityBlockingQueue 插入對象會做排序,默認參照元素 Comparable 實現, // 或者顯示地傳遞 Comparator queue.put(9); queue.put(1); queue.put(8); System.out.println("queue.size() =" + queue.size()); System.out.println("queue.take() =" + queue.take()); System.out.println("queue =" + queue); } }
運行結果:
queue.size() = 3 queue.take() = 1 queue = [8,9]7、SYNCHRONOUSQUEUE 請評估以下程序的運行結果?
public class SynchronusQueueQuiz{ public static void main(String[] args) throws Exception { BlockingQueuequeue = new SynchronousQueue<>(); // 1. SynchronousQueue 是無空間,offer 永遠返回 false // 2. SynchronousQueue take() 方法會被阻塞,必須被其他線程顯示地調用 put(Object); System.out.pringln("queue.offer(1) = " + queue.offer(1)); System.out.pringln("queue.offer(2) = " + queue.offer(2)); System.out.pringln("queue.offer(3) = " + queue.offer(3)); System.out.println("queue.take() = " + queue.take()); System.out.println("queue.size = " + queue.size()); } }
運行結果:
queue.offer(1) = false queue.offer(2) = false queue.offer(3) = false
SynchronousQueue take() 方法會被阻塞
8、BLOCKINGQUEUE OFFER() 請評估以下程序的運行結果?public class BlockingQueueQuiz{ public static void main(String[] args) throws Exception { offer(new ArrayBlockingQueue<>(2)); offer(new LinkedBlockingQueue<>(2)); offer(new PriorityBlockingQueue<>(2)); offer(new SynchronousQueue<>()); } } private static void offer(BlockingQueuequeue) throws Exception { System.out.println("queue.getClass() = " +queue.getClass().getName()); System.out.println("queue.offer(1) = " + queue.offer(1)); System.out.println("queue.offer(2) = " + queue.offer(2)); System.out.println("queue.offer(3) = " + queue.offer(3)); System.out.println("queue.size() = " + queue.size()); System.out.println("queue.take() = " + queue.take()); } }
運行結果:
queue.getClass() = java.util.concurrent.ArrayBlockingQueue queue.offer(1) = true queue.offer(2) = true queue.offer(3) = false queue.size() = 2 queue.take() = 1 queue.getClass() = java.util.concurrent.LinkedBlockingQueue queue.offer(1) = true queue.offer(2) = true queue.offer(3) = false queue.size() = 2 queue.take() = 1 queue.getClass() = java.util.concurrent.PriorityBlockingQueue queue.offer(1) = true queue.offer(2) = true queue.offer(3) = false queue.size() = 3 queue.take() = 1 queue.getClass() = java.util.concurrent.SynchronousQueue queue.offer(1) = false queue.offer(2) = false queue.offer(3) = false queue.size() = 0
queue.take() 方法會被阻塞
Java 并發框架 1、鎖 LOCK 基本版請說明 ReentranLock 與 ReentrantReadWriteLock 的區別?
jdk 1.5 以后,ReentranLock(重進入鎖)與 ReentrantReadWriteLock 都是可重進入的鎖,ReentranLock 都是互斥的,而 ReentrantReadWriteLock 是共享的,其中里面有兩個類,一個是 ReadLock(共享,并行,強調數據一致性或者說可見性),另一個是 WriteLock(互斥,串行)。
進階版請解釋 ReentrantLock 為什么命名為重進入?
public class ReentrantLockQuestion { /** * T1 , T2 , T3 * * T1(lock) , T2(park), T3(park) * Waited Queue -> Head-> T2 next -> T3 * T1(unlock) -> unpark all * Waited Queue -> Head-> T2 next -> T3 * T2(free), T3(free) * * -> T2(lock) , T3(park) * Waited Queue -> Head-> T3 * T2(unlock) -> unpark all * T3(free) */ private static ReentrantLock lock = new ReentrantLock(); public static void main(String[] args) { // thread[main] -> // lock lock lock // main -> action1() -> action2() -> action3() synchronizedAction(ReentrantLockQuestion::action1); } private static void action1() { synchronizedAction(ReentrantLockQuestion::action2); } private static void action2() { synchronizedAction(ReentrantLockQuestion::action3); } private static void action3() { System.out.println("Hello,World"); } private static void synchronizedAction(Runnable runnable) { lock.lock(); try { runnable.run(); } finally { lock.unlock(); } } }勸退版
請說明 Lock#lock() 與 Lock#lockInterruptibly() 的區別?
/** * java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued * 如果當前線程已被其他線程調用了 interrupt() 方法時,這時會返回 true * acquireQueued 執行完時,interrupt 清空(false) * 再通過 selfInterrupt() 方法將狀態恢復(interrupt=true) */ public static void main(String[] args) { lockVsLockInterruptibly(); } private static void lockVsLockInterruptibly() { try { lock.lockInterruptibly(); action1(); } catch (InterruptedException e) { // 顯示地恢復中斷狀態 Thread.currentThread().interrupt(); // 當前線程并未消亡,線程池可能還在存活 } finally { lock.unlock(); } }
lock() 優先考慮獲取鎖,待獲取鎖成功后,才響應中斷。
lockInterruptibly() 優先考慮響應中斷,而不是響應鎖的普通獲取或重入獲取。
ReentrantLock.lockInterruptibly 允許在等待時由其它線程調用等待線程的 Thread.interrupt 方法來中斷等待線程的等待而直接返回,這時不用獲取鎖,而會拋出一個 InterruptedException。
ReentrantLock.lock 方法不允許 Thread.interrupt 中斷,即使檢測到 Thread.isInterrupted ,一樣會繼續嘗試獲取鎖,失敗則繼續休眠。只是在最后獲取鎖成功后再把當前線程置為 interrupted 狀態,然后再中斷線程。
2、條件變量 CONDITION 基本版請舉例說明 Condition 使用場景?
CoutDownLatch (condition 變種)
CyclicBarrier (循環屏障)
信號量/燈(Semaphore) java 9
生產者和消費者
阻塞隊列
進階版請使用 Condition 實現 “生產者-消費者問題”?
使用Condition實現生產者消費者
勸退版請解釋 Condition await() 和 signal() 與 Object wait () 和 notify() 的相同與差異?
相同:阻塞和釋放
差異:Java Thread 對象和實際 JVM 執行的 OS Thread 不是相同對象,JVM Thread 回調 Java Thread.run() 方法,同時 Thread 提供一些 native 方法來獲取 JVM Thread 狀態,當JVM thread 執行后,自動 notify()了。
while (thread.isAlive()) { // Thread 特殊的 Object // 當線程 Thread isAlive() == false 時,thread.wait() 操作會被自動釋放 synchronized (thread) { try { thread.wait(); // 到底是誰通知 Thread -> thread.notify(); // LockSupport.park(); // 死鎖發生 } catch (Exception e) { throw new RuntimeException(e); } }3、屏障 BARRIERS 基本版
請說明 CountDownLatch 與 CyclicBarrier 的區別?
CountDownLatch : 不可循環的,一次性操作(倒計時)。
public class CountDownLatchQuestion { public static void main(String[] args) throws InterruptedException { // 倒數計數 5 CountDownLatch latch = new CountDownLatch(5); ExecutorService executorService = Executors.newFixedThreadPool(5); for (int i = 0; i < 4; i++) { executorService.submit(() -> { action(); latch.countDown(); // -1 }); } // 等待完成 // 當計數 > 0,會被阻塞 latch.await(); System.out.println("Done"); // 關閉線程池 executorService.shutdown(); } private static void action() { System.out.printf("線程[%s] 正在執行... ", Thread.currentThread().getName()); // 2 } }
CyclicBarrier:可循環的, 先計數 -1,再判斷當計數 > 0 時候,才阻塞。
public class CyclicBarrierQuestion { public static void main(String[] args) throws InterruptedException { CyclicBarrier barrier = new CyclicBarrier(5); // 5 ExecutorService executorService = Executors.newFixedThreadPool(5); // 3 for (int i = 0; i < 20; i++) { executorService.submit(() -> { action(); try { // CyclicBarrier.await() = CountDownLatch.countDown() + await() // 先計數 -1,再判斷當計數 > 0 時候,才阻塞 barrier.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } }); } // 盡可能不要執行完成再 reset // 先等待 3 ms executorService.awaitTermination(3, TimeUnit.MILLISECONDS); // 再執行 CyclicBarrier reset // reset 方法是一個廢操作 barrier.reset(); System.out.println("Done"); // 關閉線程池 executorService.shutdown(); } private static void action() { System.out.printf("線程[%s] 正在執行... ", Thread.currentThread().getName()); // 2 } }進階版
請說明 Semaphore(信號量/燈) 的使用場景?
Semaphore 和Lock類似,比Lock靈活。其中有 acquire() 和 release() 兩種方法,arg 都等于 1。acquire() 會拋出 InterruptedException,同時從 sync.acquireSharedInterruptibly(arg:1)可以看出是讀模式(shared); release()中可以計數,可以控制數量,permits可以傳遞N個數量。
Java中Semaphore(信號量)的使用
勸退版請通過 Java 1.4 的語法實現一個 CountDownLatch?
public class LegacyCountDownLatchDemo { public static void main(String[] args) throws InterruptedException { // 倒數計數 5 MyCountDownLatch latch = new MyCountDownLatch(5); ExecutorService executorService = Executors.newFixedThreadPool(5); for (int i = 0; i < 5; i++) { executorService.submit(() -> { action(); latch.countDown(); // -1 }); } // 等待完成 // 當計數 > 0,會被阻塞 latch.await(); System.out.println("Done"); // 關閉線程池 executorService.shutdown(); } private static void action() { System.out.printf("線程[%s] 正在執行... ", Thread.currentThread().getName()); // 2 } /** * Java 1.5+ Lock 實現 */ private static class MyCountDownLatch { private int count; private final Lock lock = new ReentrantLock(); private final Condition condition = lock.newCondition(); private MyCountDownLatch(int count) { this.count = count; } public void await() throws InterruptedException { // 當 count > 0 等待 if (Thread.interrupted()) { throw new InterruptedException(); } lock.lock(); try { while (count > 0) { condition.await(); // 阻塞當前線程 } } finally { lock.unlock(); } } public void countDown() { lock.lock(); try { if (count < 1) { return; } count--; if (count < 1) { // 當數量減少至0時,喚起被阻塞的線程 condition.signalAll(); } } finally { lock.unlock(); } } } /** * Java < 1.5 實現 */ private static class LegacyCountDownLatch { private int count; private LegacyCountDownLatch(int count) { this.count = count; } public void await() throws InterruptedException { // 當 count > 0 等待 if (Thread.interrupted()) { throw new InterruptedException(); } synchronized (this) { while (count > 0) { wait(); // 阻塞當前線程 } } } public void countDown() { synchronized (this) { if (count < 1) { return; } count--; if (count < 1) { // 當數量減少至0時,喚起被阻塞的線程 notifyAll(); } } } } }4、線程池 THREAD POOL 基本版
請問 J.U.C 中內建了幾種 ExceptionService 實現?
1.5:ThreadPoolExecutor、ScheduledThreadPoolExecutor
1.7:ForkJoinPool
public class ExecutorServiceQuestion { public static void main(String[] args) { /** * 1.5 * ThreadPoolExecutor * ScheduledThreadPoolExecutor :: ThreadPoolExecutor * 1.7 * ForkJoinPool */ ExecutorService executorService = Executors.newFixedThreadPool(2); executorService = Executors.newScheduledThreadPool(2); // executorService 不再被引用,它會被 GC -> finalize() -> shutdown() ExecutorService executorService2 = Executors.newSingleThreadExecutor(); } }進階版
請分別解釋 ThreadPoolExecutor 構造器參數在運行時的作用?
/** * Creates a new {@code ThreadPoolExecutor} with the given initial * parameters. * * @param corePoolSize the number of threads to keep in the pool, even * if they are idle, unless {@code allowCoreThreadTimeOut} is set * @param maximumPoolSize the maximum number of threads to allow in the * pool * @param keepAliveTime when the number of threads is greater than * the core, this is the maximum time that excess idle threads * will wait for new tasks before terminating. * @param unit the time unit for the {@code keepAliveTime} argument * @param workQueue the queue to use for holding tasks before they are * executed. This queue will hold only the {@code Runnable} * tasks submitted by the {@code execute} method. * @param threadFactory the factory to use when the executor * creates a new thread * @param handler the handler to use when execution is blocked * because the thread bounds and queue capacities are reached * @throws IllegalArgumentException if one of the following holds:
* {@code corePoolSize < 0}
* {@code keepAliveTime < 0}
* {@code maximumPoolSize <= 0}
* {@code maximumPoolSize < corePoolSize} * @throws NullPointerException if {@code workQueue} * or {@code threadFactory} or {@code handler} is null */ public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueueworkQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler);
corePoolSize: 核心線程池大小。這個參數是否生效取決于allowCoreThreadTimeOut變量的值,該變量默認是false,即對于核心線程沒有超時限制,所以這種情況下,corePoolSize參數是起效的。如果allowCoreThreadTimeOut為true,那么核心線程允許超時,并且超時時間就是keepAliveTime參數和unit共同決定的值,這種情況下,如果線程池長時間空閑的話最終存活的線程會變為0,也即corePoolSize參數失效。
maximumPoolSize: 線程池中最大的存活線程數。這個參數比較好理解,對于超出corePoolSize部分的線程,無論allowCoreThreadTimeOut變量的值是true還是false,都會超時,超時時間由keepAliveTime和unit兩個參數算出。
keepAliveTime: 超時時間。
unit: 超時時間的單位,秒,毫秒,微秒,納秒等,與keepAliveTime參數共同決定超時時間。
workQueue: 線程等待隊列。當調用execute方法時,如果線程池中沒有空閑的可用線程,那么就會把這個Runnable對象放到該隊列中。這個參數必須是一個實現BlockingQueue接口的阻塞隊列,因為要保證線程安全。有一個要注意的點是,只有在調用execute方法是,才會向這個隊列中添加任務,那么對于submit方法呢,難道submit方法提交任務時如果沒有可用的線程就直接扔掉嗎?當然不是,看一下AbstractExecutorService類中submit方法實現,其實submit方法只是把傳進來的Runnable對象或Callable對象包裝成一個新的Runnable對象,然后調用execute方法,并將包裝后的FutureTask對象作為一個Future引用返回給調用者。Future的阻塞特性實際是在FutureTask中實現的,具體怎么實現感興趣的話可以看一下FutureTask的源碼。
threadFactory: 線程創建工廠。用于在需要的時候生成新的線程。默認實現是Executors.defaultThreadFactory(),即new 一個Thread對象,并設置線程名稱,daemon等屬性。
handler: 拒絕策略。這個參數的作用是當提交任務時既沒有空閑線程,任務隊列也滿了,這時候就會調用handler的rejectedExecution方法。默認的實現是拋出一個RejectedExecutionException異常。
勸退版如何獲取 ThreadPoolExecutor 正在運行的線程?
public class ThreadPoolExecutorThreadQuestion { public static void main(String[] args) throws InterruptedException { // main 線程啟動子線程,子線程的創造來自于 Executors.defaultThreadFactory() ExecutorService executorService = Executors.newCachedThreadPool(); // 之前了解 ThreadPoolExecutor beforeExecute 和 afterExecute 能夠獲取當前線程數量 Set5、FUTURE 基本版threadsContainer = new HashSet<>(); setThreadFactory(executorService, threadsContainer); for (int i = 0; i < 9; i++) { // 開啟 9 個線程 executorService.submit(() -> { }); } // 線程池等待執行 3 ms executorService.awaitTermination(3, TimeUnit.MILLISECONDS); threadsContainer.stream() .filter(Thread::isAlive) .forEach(thread -> { System.out.println("線程池創造的線程 : " + thread); }); Thread mainThread = Thread.currentThread(); ThreadGroup mainThreadGroup = mainThread.getThreadGroup(); int count = mainThreadGroup.activeCount(); Thread[] threads = new Thread[count]; mainThreadGroup.enumerate(threads, true); Stream.of(threads) .filter(Thread::isAlive) .forEach(thread -> { System.out.println("線程 : " + thread); }); // 關閉線程池 executorService.shutdown(); } private static void setThreadFactory(ExecutorService executorService, Set threadsContainer) { if (executorService instanceof ThreadPoolExecutor) { ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) executorService; ThreadFactory oldThreadFactory = threadPoolExecutor.getThreadFactory(); threadPoolExecutor.setThreadFactory(new DelegatingThreadFactory(oldThreadFactory, threadsContainer)); } } private static class DelegatingThreadFactory implements ThreadFactory { private final ThreadFactory delegate; private final Set threadsContainer; private DelegatingThreadFactory(ThreadFactory delegate, Set threadsContainer) { this.delegate = delegate; this.threadsContainer = threadsContainer; } @Override public Thread newThread(Runnable r) { Thread thread = delegate.newThread(r); // cache thread threadsContainer.add(thread); return thread; } } }
如何獲取 Future 對象?
submit()
進階版請舉例 Future get() 以及 get(Long,TimeUnit) 方法的使用場景?
超時等待
InterruptedException
ExcutionException
TimeOutException
勸退版如何利用 Future 優雅地取消一個任務的執行?
public class CancellableFutureQuestion { public static void main(String[] args) { ExecutorService executorService = Executors.newSingleThreadExecutor(); Future future = executorService.submit(() -> { // 3秒內執行完成,才算正常 action(5); }); try { future.get(3, TimeUnit.SECONDS); } catch (InterruptedException e) { // Thread 恢復中斷狀態 Thread.currentThread().interrupt(); } catch (ExecutionException e) { throw new RuntimeException(e); } catch (TimeoutException e) { // 執行超時,適當地關閉 Thread.currentThread().interrupt(); // 設置中斷狀態 future.cancel(true); // 嘗試取消 } executorService.shutdown(); } private static void action(int seconds) { try { Thread.sleep(TimeUnit.SECONDS.toMillis(seconds)); // 5 - 3 // seconds - timeout = 剩余執行時間 if (Thread.interrupted()) { // 判斷并且清除中斷狀態 return; } action(); } catch (InterruptedException e) { } } private static void action() { System.out.printf("線程[%s] 正在執行... ", Thread.currentThread().getName()); // 2 } }6、VOLATILE 變量 基本版
在 Java 中,volatile 保證的是可見性還是原子性?
volatile 既有可見性又有原子性(非我及彼),可見性是一定的,原子性是看情況的。對象類型和原生類型都是可見性,原生類型是原子性。
進階版在 Java 中,volatile long 和 double 是線程安全的嗎?
volatile long 和 double 是線程安全的。
勸退版在 Java 中,volatile 底層實現是基于什么機制?
內存屏障(變量 Lock)機制:一個變量的原子性的保證。
7、原子操作 ATOMIC 基本版為什么 AtomicBoolean 內部變量使用 int 實現,而非 boolean?
操作系統有 X86 和 X64,在虛擬機中,基于boolean 實現就是用 int 實現的,用哪一種實現都可以。虛擬機只有32位和64位的,所以用32位的實現。
進階版在變量原子操作時,Atomic* CAS 操作比 synchronized 關鍵字哪個更重?
Synchronization
同線程的時候,synchronized 剛快;而多線程的時候則要分情況討論。
public class AtomicQuestion { private static int actualValue = 3; public static void main(String[] args) { AtomicInteger atomicInteger = new AtomicInteger(3); // if( value == 3 ) // value = 5 atomicInteger.compareAndSet(3, 5); // 偏向鎖 < CAS 操作 < 重鎖(完全互斥) // CAS 操作也是相對重的操作,它也是實現 synchronized 瘦鎖(thin lock)的關鍵 // 偏向鎖就是避免 CAS(Compare And Set/Swap)操作 } private synchronized static void compareAndSet(int expectedValue, int newValue) { if (actualValue == expectedValue) { actualValue = newValue; } } }勸退版
Atomic* CAS 的底層是如何實現?
匯編指令:cpmxchg (Compare and Exchange)
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/77891.html
摘要:百度網盤提取碼一面試題熟練掌握是很關鍵的,大公司不僅僅要求你會使用幾個,更多的是要你熟悉源碼實現原理,甚至要你知道有哪些不足,怎么改進,還有一些有關的一些算法,設計模式等等。 ??百度網盤??提取碼:u6C4?一、java面試題熟練掌握java是很關鍵的,大公司不僅僅要求你會使用幾個api,更多的是要你熟悉源碼實現原理,甚...
摘要:根據公司的調查,計算機科學專業在所有專業的前五年職業生涯的基礎薪資中位數中占據第一位,約為萬美元。市場現狀,產品背景十三五規劃對應年,大方向是加快壯大戰略性新興產業,打造經濟社會發展新引擎。 極客時間是極客邦科技出品的IT類知識服務產品,內容包含專欄訂閱、極客新聞、熱點專題、直播、視頻和音頻等多種形式的知識服務。極客時間服...
摘要:根據公司的調查,計算機科學專業在所有專業的前五年職業生涯的基礎薪資中位數中占據第一位,約為萬美元。市場現狀,產品背景十三五規劃對應年,大方向是加快壯大戰略性新興產業,打造經濟社會發展新引擎。 ??????百????度網盤??提取碼:u6C4?極客時間是極客邦科技出品的IT類知識服務產品,內容包含專欄訂閱、極客新聞、熱點專題...
摘要:原文鏈接編程方法論響應式與代碼設計實戰序,來自于微信公眾號次靈均閣正文內容在一月的架構和設計趨勢報告中,響應式編程和函數式仍舊編列在第一季度的早期采納者中。 原文鏈接:《Java編程方法論:響應式RxJava與代碼設計實戰》序,來自于微信公眾號:次靈均閣 正文內容 在《2019 一月的InfoQ 架構和設計趨勢報告》1中,響應式編程(Reactive Programming)和函數式...
摘要:一些知識點有哪些方法方法前端從入門菜鳥到實踐老司機所需要的資料與指南合集前端掘金前端從入門菜鳥到實踐老司機所需要的資料與指南合集歸屬于筆者的前端入門與最佳實踐。 工欲善其事必先利其器-前端實習簡歷篇 - 掘金 有幸認識很多在大廠工作的學長,在春招正式開始前為我提供很多內部推薦的機會,非常感謝他們對我的幫助。現在就要去北京了,對第一份正式的實習工作也充滿期待,也希望把自己遇到的一些問題和...
閱讀 2109·2023-04-26 00:50
閱讀 2479·2021-10-13 09:39
閱讀 2200·2021-09-22 15:34
閱讀 1605·2021-09-04 16:41
閱讀 1335·2019-08-30 15:55
閱讀 2433·2019-08-30 15:53
閱讀 1706·2019-08-30 15:52
閱讀 748·2019-08-29 16:19