0
点赞
收藏
分享

微信扫一扫

安装PyTorch详细过程

人间四月天i 03-13 22:30 阅读 2
学习Java

文章目录

Java多线程学习的关键要点和常见案例总结如下:

Java多线程学习的关键要点:

  1. 线程基础概念

    • 线程(Thread)是Java程序中执行的最小单位,可以在单个进程中并发执行多个线程。
    • 线程的生命周期包括:新建(New)、就绪(Runnable)、运行(Running)、阻塞(Blocked/Waiting/Timed Waiting)、死亡(Terminated)等状态。
  2. 线程创建

    • 继承Thread类,重写run()方法创建线程。
    • 实现Runnable接口,将其实例传递给Thread构造函数创建线程。
    • 使用Callable接口配合FutureTaskThread创建线程,可以获取线程的返回值。
  3. 线程调度与优先级

    • Java线程有优先级设置,高优先级的线程更有可能先被执行,但这不是绝对保证,由JVM自行调度决定。
  4. 线程同步

    • synchronized关键字用于实现互斥,防止数据竞争,保护共享资源的安全访问。
    • 使用Lock接口和ReentrantLock等实现显式锁,提供了比synchronized更灵活的锁定策略。
  5. 线程间的通信与协作

    • wait(), notify()notifyAll() 方法用于线程间同步和通信。
    • CountDownLatch, Semaphore, CyclicBarrier, Exchanger 等并发工具类提供更强大的线程协作机制。
  6. 线程安全与并发容器

    • 需要保证线程安全时,可以使用Collections.synchronizedXxx()包装类或者java.util.concurrent包下的并发容器,如ConcurrentHashMapCopyOnWriteArrayList等。
  7. 线程池

    • 使用ExecutorServiceThreadPoolExecutor实现线程池,可以有效地管理和复用线程,减少创建销毁线程的开销,提供统一的并发任务提交和执行策略。

案例示例:

  1. 简单线程创建示例

    class MyThread extends Thread {
        public void run() {
            System.out.println("线程正在运行...");
        }
        
        public static void main(String[] args) {
            MyThread t = new MyThread();
            t.start();
        }
    }
    
  2. 使用Runnable接口创建线程

    class RunnableExample implements Runnable {
        @Override
        public void run() {
            System.out.println("Runnable接口创建的线程运行中...");
        }
    
        public static void main(String[] args) {
            Thread thread = new Thread(new RunnableExample());
            thread.start();
        }
    }
    
  3. 线程同步示例

    class Counter {
        private int count = 0;
        public synchronized void increment() {
            count++;
        }
    }
    
    class IncrementThread extends Thread {
        private final Counter counter;
    
        IncrementThread(Counter counter) {
            this.counter = counter;
        }
    
        @Override
        public void run() {
            for (int i = 0; i < 1000; i++) {
                counter.increment();
            }
        }
    }
    
    public static void main(String[] args) {
        Counter counter = new Counter();
        Thread thread1 = new IncrementThread(counter);
        Thread thread2 = new IncrementThread(counter);
        thread1.start();
        thread2.start();
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("最终计数:" + counter.count);
    }
    
  4. 线程池使用示例

    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class ThreadPoolExample {
        public static void main(String[] args) {
            ExecutorService executor = Executors.newFixedThreadPool(5);
            for (int i = 0; i < 10; i++) {
                Runnable worker = new TaskWithResult(i);
                executor.execute(worker);
            }
            executor.shutdown(); // 关闭线程池不再接收新任务
            while (!executor.isTerminated()) {
                // 等待所有任务完成
            }
            System.out.println("所有任务已完成");
        }
    }
    
    class TaskWithResult implements Runnable {
        private int taskId;
    
        public TaskWithResult(int id) {
            this.taskId = id;
        }
    
        @Override
        public void run() {
            System.out.println("线程 " + Thread.currentThread().getId() + " 正在处理任务:" + taskId);
        }
    }
    

通过这些要点和案例,学习者可以逐步掌握Java多线程编程的基本技巧和最佳实践,进而能够编写出高效、安全的并发程序。

Java多线程编程还包括更多的高级特性和实用技巧

当然,除了上面提到的内容外,Java多线程编程还包括更多的高级特性和实用技巧:

高级主题:

  1. volatile关键字

    • volatile关键字确保了共享变量的可见性和有序性,主要用于解决多线程间的内存可见性问题。
  2. 原子操作类

    • java.util.concurrent.atomic包下提供的原子操作类如AtomicIntegerAtomicLong等,它们提供了一种线程安全的、无锁的方式来更新基本类型的值。
  3. Future与FutureTask

    • Future接口表示异步计算的结果,通过它可以取消任务的执行,查询任务是否已经完成,获取结果等。
    • FutureTask实现了Future接口和Runnable接口,可以作为一个Runnable被提交到线程池执行,并能获取到线程执行结果。
  4. 线程中断

    • 通过调用Thread.interrupt()方法可以中断线程,线程应该适时检查Thread.interrupted()isInterrupted()来响应中断请求。
  5. 守护线程(Daemon Thread)

    • 守护线程是一种特殊的线程,它的特点是当所有非守护线程都结束后,JVM会自动结束守护线程,即使守护线程还在运行。
  6. 线程局部变量(ThreadLocal)

    • ThreadLocal类为每个线程维护了一个独立的副本,每个线程都可以修改自己的副本而不会影响其他线程。

实用案例:

  1. 使用Future获取线程执行结果

    ExecutorService executor = Executors.newSingleThreadExecutor();
    Future<String> future = executor.submit(new Callable<String>() {
        @Override
        public String call() throws Exception {
            // 执行耗时任务
            Thread.sleep(1000);
            return "Task Result";
        }
    });
    
    // 主线程继续执行其他任务...
    // ...
    
    try {
        System.out.println("Future result: " + future.get()); // 获取线程执行结果
    } catch (InterruptedException | ExecutionException e) {
        e.printStackTrace();
    }
    
    executor.shutdown();
    
  2. 使用volatile解决可见性问题

    class VolatileExample {
        private volatile boolean ready;
        private int number;
    
        public void prepare() {
            // 准备数据
            number = 42;
            ready = true; // 设置标志位
        }
    
        public void printNumber() {
            while (!ready) { // 当ready为true时退出循环
                Thread.yield();
            }
            System.out.println(number);
        }
    }
    
  3. 使用ThreadLocal保存线程独享数据

    public class ThreadLocalExample {
        public static final ThreadLocal<UserContext> USER_CONTEXT = new ThreadLocal<>();
    
        public static void setUserContext(UserContext context) {
            USER_CONTEXT.set(context);
        }
    
        public static UserContext getUserContext() {
            return USER_CONTEXT.get();
        }
    }
    
    // 在处理用户请求的线程中保存用户上下文
    ThreadLocalExample.setUserContext(new UserContext(userId));
    
    // 在需要的地方获取用户上下文
    UserContext userContext = ThreadLocalExample.getUserContext();
    

以上都是Java多线程编程的重要知识点和应用场景,实际使用时应根据需求选择合适的技术手段来保证程序的正确性和效率。同时,对于线程安全问题,还应充分考虑死锁、活锁、饥饿等问题,避免在并发环境中出现难以预料的问题。

线程池的高级用法和配置:

  1. 线程池的拒绝策略

    • 当线程池的任务队列满并且线程池的线程数目达到最大时,新提交的任务将会被拒绝。Java提供了四种预定义的拒绝策略:

      • AbortPolicy(默认):抛出RejectedExecutionException异常。
      • CallerRunsPolicy:调用者所在的线程执行任务。
      • DiscardPolicy:直接丢弃任务,没有任何异常信息。
      • DiscardOldestPolicy:抛弃队列中最老的任务,尝试重新提交当前任务。
    • 也可以自定义拒绝策略,实现RejectedExecutionHandler接口。

  2. 定时任务与周期任务

    • ScheduledExecutorService接口提供了定时任务和周期任务的功能,可以使用Executors.newScheduledThreadPool()创建一个定长线程池,支持定时及周期性任务执行。

    • 示例:

      ScheduledExecutorService executor = Executors.newScheduledThreadPool(5);
      
      // 延迟3秒后执行一次
      executor.schedule(new Runnable() {
          @Override
          public void run() {
              System.out.println("延迟执行的任务");
          }
      }, 3, TimeUnit.SECONDS);
      
      // 每隔2秒执行一次
      executor.scheduleAtFixedRate(new Runnable() {
          @Override
          public void run() {
              System.out.println("周期执行的任务");
          }
      }, 0, 2, TimeUnit.SECONDS);
      
      // 在程序结束前关闭线程池
      executor.shutdown();
      
  3. 线程池监控与分析

    • ThreadPoolExecutor提供了getPoolSize()getActiveCount()getCompletedTaskCount()等方法用于获取线程池状态信息。
    • 可以通过java.util.concurrent.ThreadPoolExecutorMXBean或JMX(Java Management Extensions)进行更深度的监控和管理。

线程安全的最佳实践:

  1. 不可变对象

    • 使用不可变对象可以天然地保证线程安全,因为一旦对象创建后,其状态就不会再发生变化。
  2. 并发容器

    • java.util.concurrent包下提供的并发容器,如ConcurrentHashMapCopyOnWriteArrayListBlockingQueue等,设计上即考虑到线程安全问题,因此在多线程环境下首选这些容器。
  3. 双重检查锁定(Double-Checked Locking)

    • 用于优化懒汉式单例模式的线程安全性,仅在需要实例时才进行同步操作。
  4. 细粒度锁

    • 尽可能减小锁的粒度,例如使用ReentrantReadWriteLock读写锁分离读写操作,提高并发效率。

总结:

深入学习Java多线程编程不仅要理解线程生命周期、线程创建、线程同步、线程间的通信与协作等基础概念,还需熟练掌握线程池的使用,以及如何设计和实现线程安全的代码。同时,针对特定场景选择合适的并发工具和设计模式也是提升并发程序性能的关键。在实践中不断加深对多线程的理解,并时刻注意排查和预防潜在的并发问题。

python推荐学习汇总连接:
50个开发必备的Python经典脚本(1-10)

50个开发必备的Python经典脚本(11-20)

50个开发必备的Python经典脚本(21-30)

50个开发必备的Python经典脚本(31-40)

50个开发必备的Python经典脚本(41-50)
————————————————

​最后我们放松一下眼睛
在这里插入图片描述

举报

相关推荐

0 条评论