Java多线程示例代码编写指南 |21xrx.com

Java多线程示例代码编写指南

2023-07-03 03:02:18 深夜i -- --

Java 多线程示例代码编写指南并发编程

Java是一种优秀的编程语言，它拥有良好的跨平台性，能够帮助程序员实现各种复杂的应用程序。在Java中使用多线程技术，可以使程序具有并发性、提高程序的性能和响应速度。在本文中，我们将介绍Java多线程示例代码的编写指南。

1、创建线程

在Java中，需要通过创建线程来实现多线程。线程可以通过继承Thread类或实现Runnable接口来创建。下面是使用继承Thread类创建线程的示例代码：


class MyThread extends Thread {
  public void run() {
    System.out.println("MyThread is running...");
  }
}

使用实现Runnable接口创建线程的示例代码如下：


class MyRunnable implements Runnable {
  public void run() {
    System.out.println("MyRunnable is running...");
  }
}
class ThreadDemo {
  public static void main(String[] args) {
    MyRunnable myRunnable = new MyRunnable();
    Thread thread = new Thread(myRunnable);
    thread.start();
  }
}

2、线程同步

在多线程编程中，经常会遇到线程之间的同步问题。Java提供了synchronized关键字来解决线程同步问题。下面是使用synchronized关键字实现线程同步的示例代码：


class Counter {
  private int value = 0;
  
  public synchronized void increment() {
    value++;
  }
  
  public synchronized void decrement()
    value--;
  
  
  public synchronized int getValue()
    return value;
  
}
class ThreadDemo {
  public static void main(String[] args) {
    Counter counter = new Counter();
    Thread thread1 = new Thread(() -> {
      for (int i = 0; i < 10000; i++) {
        counter.increment();
      }
    });
    Thread thread2 = new Thread(() -> {
      for (int i = 0; i < 10000; i++) {
        counter.decrement();
      }
    });
    thread1.start();
    thread2.start();
    try {
      thread1.join();
      thread2.join();
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    System.out.println(counter.getValue());
  }
}

3、线程间通信

在多线程编程中，线程之间需要进行交互和通信。Java提供了wait()、notify()和notifyAll()等方法来实现线程间通信。下面是使用wait()和notify()方法实现线程间通信的示例代码：


class Message {
  private String message;
  private boolean empty = true;
  
  public synchronized String getMessage() {
    while (empty) {
      try {
        wait();
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
    empty = true;
    notifyAll();
    return message;
  }
  
  public synchronized void setMessage(String message) {
    while (!empty) {
      try {
        wait();
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
    empty = false;
    this.message = message;
    notifyAll();
  }
}
class Producer implements Runnable {
  private Message message;
  
  public Producer(Message message)
    this.message = message;
  
  
  public void run() {
    String messages[] = "message 2";
    for (int i = 0; i < messages.length; i++) {
      message.setMessage(messages[i]);
    }
    message.setMessage("exit");
  }
}
class Consumer implements Runnable {
  private Message message;
  
  public Consumer(Message message)
    this.message = message;
  
  
  public void run() {
    while (true) {
      String message = this.message.getMessage();
      System.out.println(message);
      if (message.equals("exit"))
        break;
      
    }
  }
}
class ThreadDemo {
  public static void main(String[] args) {
    Message message = new Message();
    Producer producer = new Producer(message);
    Consumer consumer = new Consumer(message);
    Thread producerThread = new Thread(producer);
    Thread consumerThread = new Thread(consumer);
    producerThread.start();
    consumerThread.start();
    try {
      producerThread.join();
      consumerThread.join();
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }
}

本文介绍了Java多线程示例代码的编写指南，包括创建线程、线程同步和线程间通信。使用多线程技术可以提高程序的性能和响应速度，实现更加复杂的应用程序。希望本文对大家有所帮助。

上一篇: idea打包java可执行jar包

下一篇: C++的难度系数如何评价？

评论区

()

相似文章