欢迎访问宙启技术站
智能推送

Java中的Thread函数如何实现线程的创建和同步?

发布时间:2023-07-03 23:44:21

在Java中,线程的创建和同步可以通过Thread类和synchronized关键字来实现。

1. 创建线程:

在Java中,可以通过继承Thread类或实现Runnable接口来创建线程。下面分别介绍这两种方式的实现。

a. 继承Thread类:

1) 创建一个继承自Thread类的子类,重写run()方法,在run()方法中定义线程要执行的任务。

2) 创建子类的实例对象,并调用start()方法启动线程。

示例代码如下:

      public class MyThread extends Thread {
          @Override
          public void run() {
              // 线程要执行的任务
          }

          public static void main(String[] args) {
              MyThread myThread = new MyThread();
              myThread.start();
          }
      }
      

b. 实现Runnable接口:

1) 创建一个实现了Runnable接口的类,并实现接口中的run()方法,在run()方法中定义线程要执行的任务。

2) 创建该类的实例对象,将其作为参数传递给Thread类的构造方法创建Thread对象。

3) 调用Thread对象的start()方法启动线程。

示例代码如下:

      public class MyRunnable implements Runnable {
          @Override
          public void run() {
              // 线程要执行的任务
          }

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

2. 同步线程:

在多线程环境下,由于多个线程共享同一资源,可能会出现竞态条件(Race Condition),为了避免竞态条件导致的数据不一致或错误,可以使用synchronized关键字对关键代码块或方法进行同步。

a. 同步代码块:

在需要进行同步的代码块前使用synchronized关键字,并指定一个共享对象作为锁,保证同一时刻只有一个线程执行该代码块。

示例代码如下:

      public class MyThread implements Runnable {
          private static int count = 0;

          @Override
          public void run() {
              synchronized (this) {
                  for (int i = 0; i < 100; i++) {
                      count++;
                  }
              }
          }

          public static void main(String[] args) {
              MyThread myThread = new MyThread();
              Thread thread1 = new Thread(myThread);
              Thread thread2 = new Thread(myThread);
              thread1.start();
              thread2.start();
              try {
                  thread1.join();
                  thread2.join();
              } catch (InterruptedException e) {
                  e.printStackTrace();
              }
              System.out.println(count);
          }
      }
      

b. 同步方法:

可以在方法声明中使用synchronized关键字,将整个方法声明为同步方法,保证同一时刻只有一个线程执行该方法。

示例代码如下:

      public class MyThread extends Thread {
          private static int count = 0;

          @Override
          public synchronized void run() {
              for (int i = 0; i < 100; i++) {
                  count++;
              }
          }

          public static void main(String[] args) {
              MyThread myThread = new MyThread();
              Thread thread1 = new Thread(myThread);
              Thread thread2 = new Thread(myThread);
              thread1.start();
              thread2.start();
              try {
                  thread1.join();
                  thread2.join();
              } catch (InterruptedException e) {
                  e.printStackTrace();
              }
              System.out.println(count);
          }
      }
      

通过上述方式,可以在Java中实现线程的创建和同步。创建线程可以通过继承Thread类或实现Runnable接口来实现,而线程的同步可以通过synchronized关键字来实现。使用同步代码块或同步方法可以保证在多线程访问共享资源时的数据一致性和正确性。