Java 并行编程实现方式:1. 多线程、2. 线程池、3. 锁、4. 原子变量选择合适方式取决于需求,例如:高吞吐量:多线程或线程池低响应时间:线程池或原子变量资源受限:线程池或锁
Java 并行编程的实现方式
Java 提供了多种实现并行编程的机制,包括:
如何选择合适的实现方式?
选择合适的并行编程实现方式取决于应用程序的需求:
实战案例:
使用线程池提高吞吐量:
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ThreadPoolDemo { public static void main(String[] args) { // 创建一个固定大小的线程池 ExecutorService executor = Executors.newFixedThreadPool(10); // 创建任务 Runnable task = () -> { System.out.println("Hello from thread " + Thread.currentThread().getName()); }; // 提交任务到线程池 for (int i = 0; i < 100; i++) { executor.submit(task); } // 等待所有任务完成 executor.shutdown(); while (!executor.isTerminated()) { try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } } } }
使用原子变量实现线程安全:
import java.util.concurrent.atomic.AtomicInteger; public class AtomicVariableDemo { public static void main(String[] args) { // 创建一个原子整数 AtomicInteger counter = new AtomicInteger(0); // 两个线程同时更新计数器 Thread thread1 = new Thread(() -> { for (int i = 0; i < 100000; i++) { counter.incrementAndGet(); } }); Thread thread2 = new Thread(() -> { for (int i = 0; i < 100000; i++) { counter.incrementAndGet(); } }); thread1.start(); thread2.start(); // 等待线程完成 try { thread1.join(); thread2.join(); } catch (InterruptedException e) { e.printStackTrace(); } // 打印最终计数器值 System.out.println("Final count: " + counter.get()); } }
以上是Java并行编程的实现方式有哪些?该如何选择?的详细内容。更多信息请关注PHP中文网其他相关文章!