\u901a\u8fc7\u7ee7\u627fThread\u7c7b\u5e76\u91cd\u5199run()\u65b9\u6cd5\u5b9e\u73b0\u7ebf\u7a0b\u903b\u8f91\u3002<\/p>\n
public class MyThread extends Thread {\n @Override\n public void run() {\n System.out.println("\u7ebf\u7a0b\u6267\u884c: " + Thread.currentThread().getName());\n }\n\n public static void main(String[] args) {\n MyThread thread = new MyThread();\n thread.start(); \/\/ \u542f\u52a8\u7ebf\u7a0b\uff0c\u8c03\u7528 start() \u800c\u975e run()\n }\n}<\/code><\/pre>\n\u7279\u70b9\uff1a<\/p>\n
\n- \u7b80\u5355\u76f4\u63a5\uff0c\u9002\u5408\u7b80\u5355\u573a\u666f\u3002<\/li>\n
- \u7f3a\u70b9\uff1aJava\u4e0d\u652f\u6301\u591a\u7ee7\u627f\uff0c\u7ee7\u627fThread\u7c7b\u540e\u65e0\u6cd5\u518d\u7ee7\u627f\u5176\u4ed6\u7c7b\u3002<\/li>\n<\/ul>\n
\u5b9e\u73b0Runnable\u63a5\u53e3<\/h3>\n
\u901a\u8fc7\u5b9e\u73b0Runnable\u63a5\u53e3\u7684run()\u65b9\u6cd5\uff0c\u5c06\u4efb\u52a1\u903b\u8f91\u4e0e\u7ebf\u7a0b\u5206\u79bb\u3002<\/p>\n
public class MyRunnable implements Runnable {\n @Override\n public void run() {\n System.out.println("\u7ebf\u7a0b\u6267\u884c: " + Thread.currentThread().getName());\n }\n\n public static void main(String[] args) {\n Thread thread = new Thread(new MyRunnable());\n thread.start();\n }\n}<\/code><\/pre>\n\u7279\u70b9\uff1a<\/p>\n
\n- \u66f4\u7075\u6d3b\uff0c\u907f\u514d\u5355\u7ee7\u627f\u7684\u9650\u5236\u3002<\/li>\n
- \u63a8\u8350\u65b9\u6cd5\uff0c\u9002\u5408\u4efb\u52a1\u4e0e\u7ebf\u7a0b\u89e3\u8026\u7684\u573a\u666f\u3002<\/li>\n<\/ul>\n
\u5b9e\u73b0Callable\u63a5\u53e3+Future<\/h3>\n
\u901a\u8fc7Callable\u63a5\u53e3\u5b9e\u73b0\u5e26\u8fd4\u56de\u503c\u7684\u7ebf\u7a0b\u4efb\u52a1\uff0c\u7ed3\u5408Future\u6216FutureTask\u83b7\u53d6\u7ed3\u679c\u3002<\/p>\n
import java.util.concurrent.*;\n\npublic class MyCallable implements Callable<String> {\n @Override\n public String call() throws Exception {\n return "\u4efb\u52a1\u5b8c\u6210: " + Thread.currentThread().getName();\n }\n\n public static void main(String[] args) throws Exception {\n ExecutorService executor = Executors.newSingleThreadExecutor();\n Future<String> future = executor.submit(new MyCallable());\n System.out.println(future.get()); \/\/ \u963b\u585e\u76f4\u5230\u4efb\u52a1\u5b8c\u6210\n executor.shutdown();\n }\n}<\/code><\/pre>\n\u7279\u70b9\uff1a<\/p>\n
\n- \u652f\u6301\u8fd4\u56de\u503c\uff0c\u53ef\u629b\u51fa\u5f02\u5e38\u3002<\/li>\n
- \u914d\u5408\u7ebf\u7a0b\u6c60\u4f7f\u7528\u66f4\u9ad8\u6548\u3002<\/li>\n<\/ul>\n
\u4f7f\u7528\u7ebf\u7a0b\u6c60\uff08ExecutorService\uff09<\/h3>\n
\u901a\u8fc7\u7ebf\u7a0b\u6c60\u7ba1\u7406\u7ebf\u7a0b\u8d44\u6e90\uff0c\u907f\u514d\u9891\u7e41\u521b\u5efa\u548c\u9500\u6bc1\u7ebf\u7a0b\u7684\u5f00\u9500\u3002<\/p>\n
import java.util.concurrent.*;\n\npublic class ThreadPoolDemo {\n public static void main(String[] args) {\n ExecutorService executor = Executors.newFixedThreadPool(3);\n for (int i = 0; i < 5; i++) {\n executor.execute(() -> {\n System.out.println("\u7ebf\u7a0b\u6267\u884c: " + Thread.currentThread().getName());\n });\n }\n executor.shutdown(); \/\/ \u5173\u95ed\u7ebf\u7a0b\u6c60\n }\n}<\/code><\/pre>\n\u7279\u70b9\uff1a<\/p>\n
\n- \u8d44\u6e90\u590d\u7528\uff0c\u63d0\u9ad8\u6027\u80fd\u3002<\/li>\n
- \u652f\u6301\u4efb\u52a1\u961f\u5217\u3001\u62d2\u7edd\u7b56\u7565\u7b49\u9ad8\u7ea7\u914d\u7f6e\u3002<\/li>\n<\/ul>\n
\u57fa\u4e8eLambda\u8868\u8fbe\u5f0f\uff08\u7b80\u5316\u5199\u6cd5\uff09<\/h3>\n
Java8+\u652f\u6301\u7528Lambda\u8868\u8fbe\u5f0f\u7b80\u5316Runnable\u6216Callable\u7684\u5199\u6cd5\u3002<\/p>\n
public class LambdaThread {\n public static void main(String[] args) {\n \/\/ Runnable \u7684 Lambda \u7b80\u5316\n new Thread(() -> System.out.println("Lambda\u7ebf\u7a0b\u6267\u884c")).start();\n\n \/\/ Callable \u7684 Lambda \u7b80\u5316\n ExecutorService executor = Executors.newSingleThreadExecutor();\n Future<String> future = executor.submit(() -> "Lambda\u4efb\u52a1\u5b8c\u6210");\n }\n}<\/code><\/pre>\n\u5f02\u6b65\u7f16\u7a0bCompletableFuture<\/h3>\n
\u57fa\u4e8eFuture\u6a21\u5f0f\uff0c\u652f\u6301\u975e\u963b\u585e\u7ec4\u5408\u64cd\u4f5c\u548c\u51fd\u6570\u5f0f\u7f16\u7a0b\u3002\u5176\u6838\u5fc3\u7279\u6027\u5305\u62ec\uff1a<\/p>\n
\n- \u5f02\u6b65\u6267\u884c\uff1a\u4efb\u52a1\u63d0\u4ea4\u540e\u7acb\u5373\u8fd4\u56deCompletableFuture\u5bf9\u8c61\u3002<\/li>\n
- \u94fe\u5f0f\u8c03\u7528\uff1a\u901a\u8fc7thenApply\u3001thenCompose\u7b49\u65b9\u6cd5\u4e32\u8054\u591a\u4e2a\u64cd\u4f5c\u3002<\/li>\n
- \u7ec4\u5408\u64cd\u4f5c\uff1a\u5408\u5e76\u591a\u4e2aFuture\uff08\u5982allOf\u3001anyOf\uff09\u3002<\/li>\n
- \u5f02\u5e38\u5904\u7406\uff1a\u901a\u8fc7exceptionally\u6216handle\u6355\u83b7\u5f02\u5e38\u3002<\/li>\n
- \n
\u4efb\u52a1\u63d0\u4ea4\uff1a<\/p>\n
CompletableFuture.supplyAsync(() -> "Hello", executor); \/\/ \u5e26\u8fd4\u56de\u503c\nCompletableFuture.runAsync(() -> System.out.println("Run"), executor); \/\/ \u65e0\u8fd4\u56de\u503c<\/code><\/pre>\n<\/li>\n- \n
\u7ed3\u679c\u5904\u7406\uff1a<\/p>\n
\n- thenApply\uff1a\u540c\u6b65\u8f6c\u6362\u7ed3\u679c\u3002<\/li>\n
- thenApplyAsync\uff1a\u5f02\u6b65\u8f6c\u6362\u7ed3\u679c\uff08\u4f7f\u7528\u9ed8\u8ba4\u6216\u6307\u5b9a\u7ebf\u7a0b\u6c60\uff09\u3002<\/li>\n<\/ul>\n<\/li>\n
- \n
\u7ed3\u679c\u5408\u5e76\uff1a<\/p>\n
\n- thenCombine\uff1a\u5408\u5e76\u4e24\u4e2aFuture\u7684\u7ed3\u679c\u3002<\/li>\n
- thenCompose\uff1a\u4e32\u8054\u4e24\u4e2aFuture\uff08\u524d\u4e00\u4e2a\u7ed3\u679c\u4f5c\u4e3a\u4e0b\u4e00\u4e2a\u8f93\u5165\uff09\u3002<\/li>\n<\/ul>\n<\/li>\n
- \n
\u7ec4\u5408\u591a\u4e2aFuture\uff1a<\/p>\n
\n- allOf\uff1a\u7b49\u5f85\u6240\u6709Future\u5b8c\u6210\u3002<\/li>\n
- anyOf\uff1a\u4efb\u610f\u4e00\u4e2aFuture\u5b8c\u6210\u5373\u7ee7\u7eed\u3002<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
\u7ebf\u7a0b\u5b89\u5168<\/h3>\n
\u5f53\u591a\u4e2a\u7ebf\u7a0b\u8bbf\u95ee\u5171\u4eab\u8d44\u6e90\uff08\u53d8\u91cf\u3001\u5bf9\u8c61\u3001\u6587\u4ef6\u7b49\uff09\u65f6\uff0c\u82e5\u672a\u6b63\u786e\u540c\u6b65\uff0c\u53ef\u80fd\u5bfc\u81f4\uff1a<\/p>\n
\n- \u7ade\u6001\u6761\u4ef6\uff1a\u7ed3\u679c\u4f9d\u8d56\u7ebf\u7a0b\u6267\u884c\u987a\u5e8f\u3002<\/li>\n
- \u6570\u636e\u4e0d\u4e00\u81f4\uff1a\u5982\u810f\u8bfb\u3001\u4e0d\u53ef\u91cd\u590d\u8bfb\u3002<\/li>\n
- \u6b7b\u9501\/\u6d3b\u9501\uff1a\u73b0\u6210\u4e92\u76f8\u7b49\u5f85\u6216\u65e0\u6cd5\u63a8\u8fdb\u3002<\/li>\n<\/ul>\n
\u73b0\u6210\u5b89\u5168\u89e3\u51b3\u65b9\u6848<\/h4>\n\n- \u65e0\u72b6\u6001\u5bf9\u8c61
\u65e0\u5171\u4eab\u6570\u636e\uff1a\u65b9\u6cd5\u5185\u5c40\u90e8\u53d8\u91cf\u4e0d\u8de8\u7ebf\u7a0b\u5171\u4eab\uff0c\u5929\u7136\u7ebf\u7a0b\u5b89\u5168\u3002<\/li>\n<\/ol>\npublic class Stateless {\n public int add(int a, int b) {\n return a + b; \/\/ \u65e0\u6210\u5458\u53d8\u91cf\uff0c\u7ebf\u7a0b\u5b89\u5168\n }\n}<\/code><\/pre>\n\n- \u4e0d\u53ef\u53d8\u5bf9\u8c61
\u5bf9\u8c61\u4e00\u65e6\u521b\u5efa\uff0c\u72b6\u6001\u4e0d\u53ef\u4fee\u6539\u3002<\/li>\n<\/ol>\npublic final class ImmutableObject {\n private final int value;\n public ImmutableObject(int value) {\n this.value = value;\n }\n public int getValue() { return value; }\n}<\/code><\/pre>\n\n- \u7ebf\u7a0b\u5c01\u95ed
\u6808\u5c01\u95ed\uff1a\u5c40\u90e8\u53d8\u91cf\u4ec5\u5b58\u5728\u4e8e\u7ebf\u7a0b\u6808\u4e2d\u3002
ThreadLocal\uff1a\u4e3a\u6bcf\u4e2a\u7ebf\u7a0b\u521b\u5efa\u72ec\u7acb\u526f\u672c\u3002<\/li>\n<\/ol>\npublic class ThreadLocalExample {\n private static ThreadLocal<SimpleDateFormat> dateFormat =\n ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd"));\n}<\/code><\/pre>\n\n- \u540c\u6b65\u4ee3\u7801\u5757
\u4f7f\u7528synchronized\u5173\u952e\u5b57\u9501\u5b9a\u5171\u4eab\u8d44\u6e90\u3002<\/li>\n<\/ol>\npublic class Counter {\n private int count = 0;\n public synchronized void increment() { count++; }\n public synchronized int getCount() { return count; }\n}<\/code><\/pre>\n\n- \u663e\u5f0f\u9501\uff08ReentrantLock\uff09
\u66f4\u7075\u6d3b\u7684\u9501\u673a\u5236\uff0c\u652f\u6301\u8d85\u65f6\u3001\u53ef\u4e2d\u65ad\u3001\u516c\u5e73\u9501\u3002<\/li>\n<\/ol>\npublic class Counter {\n private int count = 0;\n private final ReentrantLock lock = new ReentrantLock();\n \n public void increment() {\n lock.lock();\n try {\n count++;\n } finally {\n lock.unlock();\n }\n }\n}<\/code><\/pre>\n\n- \u539f\u5b50\u7c7b\uff08Atomic Classes\uff09
\u57fa\u4e8eCAS\uff08Compare-And-Swap\uff09\u7684\u65e0\u9501\u64cd\u4f5c\uff0c\u9002\u5408\u8ba1\u6570\u5668\u7b49\u573a\u666f\u3002<\/li>\n<\/ol>\npublic class AtomicCounter {\n private AtomicInteger count = new AtomicInteger(0);\n public void increment() { count.incrementAndGet(); }\n}<\/code><\/pre>\n\n- \u5e76\u53d1\u5bb9\u5668
\u4f7f\u7528ConcurrentHashMap\u3001CopyOnWriteArrayList\u7b49\u7ebf\u7a0b\u5b89\u5168\u5bb9\u5668\u3002<\/li>\n<\/ol>\nMap<String, String> map = new ConcurrentHashMap<>();\nList<String> list = new CopyOnWriteArrayList<>();<\/code><\/pre>\n\n- \u8bfb\u5199\u9501
\u8bfb\u64cd\u4f5c\u5171\u4eab\uff0c\u5199\u64cd\u4f5c\u4e92\u65a5\uff0c\u63d0\u5347\u8bfb\u591a\u5199\u5c11\u573a\u666f\u7684\u6027\u80fd\u3002<\/li>\n<\/ol>\npublic class CachedData {\n private final ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();\n private Object data;\n\n public void update(Object newData) {\n rwl.writeLock().lock();\n try {\n data = newData;\n } finally {\n rwl.writeLock().unlock();\n }\n }\n\n public Object read() {\n rwl.readLock().lock();\n try {\n return data;\n } finally {\n rwl.readLock().unlock();\n }\n }\n}<\/code><\/pre>\n