java多线程简单介绍和代码实例

阳光穿透心脏的1/2处 2023-10-13 10:32 98阅读 0赞

**Java提供了强大的多线程支持，可以使用多种方式实现多线程编程。下面是一些常见的Java多线程编程的方式和工具：**

1.  Thread类：Java的基本多线程编程是通过Thread类来实现的。创建一个Thread的子类，重写run方法，并在其中定义线程的逻辑。然后通过创建Thread的实例并调用start方法来启动线程。

class MyThread extends Thread {
        
       public void run() {
        
           // 线程的逻辑
       }
    }
    
    public class Main {
        
       public static void main(String[] args) {
        
           MyThread thread = new MyThread();
           thread.start();
       }
    }

**Runnable接口**：除了继承Thread类，还可以通过实现Runnable接口来实现多线程。创建一个实现了Runnable接口的类，实现其run方法，并在其中定义线程的逻辑。然后将实现了Runnable接口的对象传递给Thread类的构造方法，并调用start方法启动线程。

class MyRunnable implements Runnable {
        
        public void run() {
        
            // 线程的逻辑
        }
    }
    
    public class Main {
        
        public static void main(String[] args) {
        
            MyRunnable runnable = new MyRunnable();
            Thread thread = new Thread(runnable);
            thread.start();
        }
    }

Callable和Future：除了使用Runnable，还可以使用Callable接口来定义线程的逻辑，并通过Future接口获取线程的返回结果。Callable可以返回一个结果，而Runnable没有返回值。

import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.FutureTask;
    
    class MyCallable implements Callable<Integer> {
        
        public Integer call() {
        
            // 线程的逻辑，并返回一个结果
            return 42;
        }
    }
    
    public class Main {
        
        public static void main(String[] args) throws ExecutionException, InterruptedException {
        
            MyCallable callable = new MyCallable();
            FutureTask<Integer> futureTask = new FutureTask<>(callable);
            Thread thread = new Thread(futureTask);
            thread.start();
    
            // 获取线程的返回结果
            int result = futureTask.get();
            System.out.println("线程的返回结果：" + result);
        }
    }

**Executor框架**：Java提供了Executor框架来管理和调度线程执行。它抽象了线程的创建和调度过程，提供了更高级的任务提交和执行的接口。

import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class Main {
        
        public static void main(String[] args) {
        
            ExecutorService executorService = Executors.newFixedThreadPool(5);
    
            // 提交任务给线程池
            executorService.submit(() -> {
        
                // 线程的逻辑
            });
    
            // 关闭线程池
            executorService.shutdown();
        }
    }

Java还提供了诸如线程同步、锁、条件变量、并发容器等更高级的多线程工具和技术，如synchronized关键字、Lock接口、CountDownLatch、CyclicBarrier、Semaphore等 可以自行搜索一下