Java多线程代码编写 |21xrx.com

Java多线程代码编写

2023-07-05 05:15:59 深夜i -- --

Java 多线程代码编写

Java多线程编程是一种采用并发编程的方法，它能够使程序更加高效地利用计算机处理器的资源，提高程序性能和响应速度，同时也能够提供更好的用户体验。下面将介绍Java多线程代码的编写方法。

1. 实现Runnable接口

实现Runnable接口是Java多线程编程的基础，它的声明如下：


public interface Runnable {
  void run();
}

我们需要实现run()方法，在该方法中编写具体的多线程代码。下面是一个简单的示例代码：


public class MyRunnable implements Runnable {
  @Override
  public void run() {
    System.out.println("MyRunnable is running.");
  }
}

在这个示例代码中，我们创建了一个类MyRunnable，它实现了Runnable接口，并重写了run()方法。在这个方法中，我们打印了一条信息。

2. 创建线程

为了运行上面的示例代码，我们需要创建一个线程，并启动它。创建线程的方法有两种：继承Thread类和实现Runnable接口。这里我们介绍实现Runnable接口的方法。


public class Main {
  public static void main(String[] args) {
    MyRunnable myRunnable = new MyRunnable();
    Thread thread = new Thread(myRunnable);
    thread.start();
  }
}

在这个示例代码中，我们创建了一个MyRunnable对象，然后创建了一个Thread对象，并把MyRunnable对象传递给Thread的构造函数。最后，我们调用了Thread对象的start()方法来启动线程。

3. 线程同步

在多线程编程中，为了防止多个线程同时操作共享的资源而引起的错误，我们需要进行线程同步。Java提供了两种线程同步的机制：synchronized关键字和Lock接口。

下面是一个使用synchronized关键字进行线程同步的示例代码：


public class MyThread extends Thread {
  private String name;
  private MyObject myObject;
  public MyThread(String name, MyObject myObject)
    this.name = name;
    this.myObject = myObject;
  
  @Override
  public void run() {
    synchronized (myObject) {
      myObject.print(name);
    }
  }
}
public class MyObject {
  public synchronized void print(String name) {
    for (int i = 0; i <= 5; ++i) {
      System.out.println(name + " " + i);
    }
  }
}
public class Main {
  public static void main(String[] args) {
    MyObject myObject = new MyObject();
    MyThread thread1 = new MyThread("Thread 1", myObject);
    MyThread thread2 = new MyThread("Thread 2", myObject);
    thread1.start();
    thread2.start();
  }
}

在这个示例代码中，我们定义了一个MyObject类，它有一个print()方法，这个方法使用synchronized关键字来同步多个线程对共享的资源的访问。我们创建了两个MyThread对象，并调用它们的start()方法，这将启动两个线程，并且它们都使用同一个MyObject对象。

4. 线程通信

线程通信是多线程编程中的另一个重要的概念。它指的是多个线程之间的协调和交流，使得它们能够正确地完成任务。Java提供了两种线程通信的机制：wait()和notify()方法以及Lock和Condition接口。

下面是一个使用wait()和notify()方法进行线程通信的示例代码：


public class MyThread extends Thread {
  private String name;
  private MyObject myObject;
  public MyThread(String name, MyObject myObject)
    this.name = name;
    this.myObject = myObject;
  
  @Override
  public void run() {
    try {
      if (name.equals("Thread 1")) {
        myObject.wait();
      }
      myObject.print(name);
      if (name.equals("Thread 2")) {
        myObject.notify();
      }
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }
}
public class MyObject {
  private boolean flag = false;
  public synchronized void print(String name) throws InterruptedException {
    if (!flag) {
      wait();
    }
    for (int i = 0; i <= 5; ++i) {
      System.out.println(name + " " + i);
    }
    flag = false;
    notify();
  }
  public synchronized void setFlag(boolean flag)
    this.flag = flag;
  
}
public class Main {
  public static void main(String[] args) throws InterruptedException {
    MyObject myObject = new MyObject();
    myObject.setFlag(true);
    MyThread thread1 = new MyThread("Thread 1", myObject);
    MyThread thread2 = new MyThread("Thread 2", myObject);
    thread1.start();
    thread2.start();
  }
}

在这个示例代码中，我们定义了一个MyObject类，它有一个print()方法和一个setFlag()方法。print()方法使用wait()和notify()方法来进行线程通信。setFlag()方法用来设置一个共享变量flag的值。

我们创建了两个MyThread对象，并调用它们的start()方法，这将启动两个线程。在这个示例代码中，我们让第一个线程等待（使用wait()方法）并且让第二个线程通知（使用notify()方法）它。这样做的目的是让这两个线程按照我们想要的顺序输出信息。

以上就是Java多线程代码的编写方法，我们可以根据实际需求来选择合适的技术，并将其应用到我们的程序中。

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

下一篇: 方法实现？

评论区

()

相似文章