正文

java多线程怎么并发

小六 /48 浏览量
0103

在Java中实现多线程并发可以通过以下几种方式：

继承Thread类

创建一个继承自`Thread`类的子类，并重写`run（）`方法来定义线程执行的代码。

创建子类对象，并调用`start（）`方法启动线程。

 class MyThread extends Thread { public void run（） { // 线程执行的代码 } } public class Main { public static void main（String[] args） { MyThread thread1 = new MyThread（）； MyThread thread2 = new MyThread（）； thread1.start（）； thread2.start（）； } }

实现Runnable接口

创建一个实现了`Runnable`接口的类，并实现其`run（）`方法。

创建实现类的对象，并通过`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（）； } }

使用Executor框架

通过`Executors`类中的静态方法创建不同类型的线程池，如`newFixedThreadPool（）`、`newCachedThreadPool（）`等。

将任务提交给线程池执行。

 ExecutorService executor = Executors.newFixedThreadPool（2）； executor.execute（new Runnable（） { public void run（） { // 线程执行的代码 } }）； executor.shutdown（）；

使用Callable和Future

`Callable`接口可以返回线程执行的结果。

通过`ExecutorService`的`submit（）`方法将`Callable`任务提交给线程池执行，返回一个`Future`对象。

通过调用`Future`对象的`get（）`方法获取执行结果。

 ExecutorService executor = Executors.newSingleThreadExecutor（）； Future 
  
    
  
    result = executor.submit（new Callable 
   
     （） { 
    
   public Integer call（） throws Exception { // 线程执行的代码，返回结果 return 0； } }）； Integer result = result.get（）； executor.shutdown（）；

同步控制

使用`synchronized`关键字进行同步，确保多个线程按照指定的顺序执行，避免数据竞争和并发问题。

 public class SynchronizedExample { private int counter = 0； public synchronized void increment（） { counter++； } public synchronized int getCounter（） { return counter； } }

使用`Lock`接口及其实现类（如`ReentrantLock`），提供更灵活的线程同步机制。

 import java.util.concurrent.locks.Lock； import java.util.concurrent.locks.ReentrantLock； public class LockExample { private int counter = 0； private final Lock lock = new ReentrantLock（）； public void increment（） { lock.lock（）； try { counter++； } finally { lock.unlock（）； } } }

其他并发控制方法

使用`volatile`关键字声明共享变量，确保多线程环境下的可见性。

使用线程安全的容器类，如`ConcurrentHashMap`和`ConcurrentLinkedQueue`。

使用并发工具类，如`CountDownLatch`、`CyclicBarrier`和`Semaphore`等。

以上方法可以帮助你在Java中实现多线程的并发执行

-- 展开阅读全文 --