Java — многопоточность

class ThreadDemo extends Thread {
   private Thread t;
   private String threadName;
   
   ThreadDemo( String name) {
      threadName = name;
      System.out.println("Creating " +  threadName );
   }
   
   public void run() {
      System.out.println("Running " +  threadName );
      try {
         for(int i = 4; i > 0; i--) {
            System.out.println("Thread: " + threadName + ", " + i);
            // Let the thread sleep for a while.
            Thread.sleep(50);
         }
      } catch (InterruptedException e) {
         System.out.println("Thread " +  threadName + " interrupted.");
      }
      System.out.println("Thread " +  threadName + " exiting.");
   }
   
   public void start () {
      System.out.println("Starting " +  threadName );
      if (t == null) {
         t = new Thread (this, threadName);
         t.start ();
      }
   }
}

public class TestThread {

   public static void main(String args[]) {
      ThreadDemo T1 = new ThreadDemo( "Thread-1");
      T1.start();
      
      ThreadDemo T2 = new ThreadDemo( "Thread-2");
      T2.start();
   }   
}

Это даст следующий результат —

Выход

Creating Thread-1
Starting Thread-1
Creating Thread-2
Starting Thread-2
Running Thread-1
Thread: Thread-1, 4
Running Thread-2
Thread: Thread-2, 4
Thread: Thread-1, 3
Thread: Thread-2, 3
Thread: Thread-1, 2
Thread: Thread-2, 2
Thread: Thread-1, 1
Thread: Thread-2, 1
Thread Thread-1 exiting.
Thread Thread-2 exiting.

Методы потока

Ниже приведен список важных методов, доступных в классе Thread.

public void start ()

Запускает поток по отдельному пути выполнения, затем вызывает метод run () для этого объекта Thread.

public void run ()

Если этот объект Thread был создан с использованием отдельной цели Runnable, метод run () вызывается для этого объекта Runnable.

публичный финал void setName (имя строки)

Изменяет имя объекта Thread. Существует также метод getName () для получения имени.

public final void setPriority (int priority)

Устанавливает приоритет этого объекта Thread. Возможные значения от 1 до 10.

публичный финал void setDaemon (логическое значение включено)

Параметр true обозначает этот поток как поток демона.

публичное окончание void join (длинный миллисек)

Текущий поток вызывает этот метод во втором потоке, в результате чего текущий поток блокируется до тех пор, пока второй поток не завершится или не пройдет указанное количество миллисекунд.

public void interrupt ()

Прерывает этот поток, заставляя его продолжить выполнение, если он был заблокирован по какой-либо причине.

открытый финальный логический isAlive ()

Возвращает true, если поток активен, что происходит в любое время после запуска потока, но до его завершения.

Предыдущие методы вызываются для определенного объекта Thread. Следующие методы в классе Thread являются статическими. Вызов одного из статических методов выполняет операцию с текущим запущенным потоком.

public static void yield ()

Заставляет текущий запущенный поток уступать любым другим потокам с тем же приоритетом, которые ожидают, чтобы быть запланированными.

Публичный статический бессильный сон (длинный миллисек)

Заставляет текущий запущенный поток блокироваться как минимум на указанное количество миллисекунд.

public static boolean holdLock (Объект x)

Возвращает true, если текущий поток удерживает блокировку данного объекта.

публичный статический поток currentThread ()

Возвращает ссылку на текущий запущенный поток, который является потоком, который вызывает этот метод.

public static void dumpStack ()

Печатает трассировку стека для текущего запущенного потока, что полезно при отладке многопоточного приложения.

пример

Следующая программа ThreadClassDemo демонстрирует некоторые из этих методов класса Thread. Рассмотрим класс DisplayMessage, который реализует Runnable —

// File Name : DisplayMessage.java
// Create a thread to implement Runnable

public class DisplayMessage implements Runnable {
   private String message;
   
   public DisplayMessage(String message) {
      this.message = message;
   }
   
   public void run() {
      while(true) {
         System.out.println(message);
      }
   }
}

Ниже приведен еще один класс, расширяющий класс Thread.

// File Name : GuessANumber.java
// Create a thread to extentd Thread

public class GuessANumber extends Thread {
   private int number;
   public GuessANumber(int number) {
      this.number = number;
   }
   
   public void run() {
      int counter = 0;
      int guess = 0;
      do {
         guess = (int) (Math.random() * 100 + 1);
         System.out.println(this.getName() + " guesses " + guess);
         counter++;
      } while(guess != number);
      System.out.println("** Correct!" + this.getName() + "in" + counter + "guesses.**");
   }
}

Ниже приводится основная программа, в которой используются определенные выше классы.

// File Name : ThreadClassDemo.java
public class ThreadClassDemo {

   public static void main(String [] args) {
      Runnable hello = new DisplayMessage("Hello");
      Thread thread1 = new Thread(hello);
      thread1.setDaemon(true);
      thread1.setName("hello");
      System.out.println("Starting hello thread...");
      thread1.start();
      
      Runnable bye = new DisplayMessage("Goodbye");
      Thread thread2 = new Thread(bye);
      thread2.setPriority(Thread.MIN_PRIORITY);
      thread2.setDaemon(true);
      System.out.println("Starting goodbye thread...");
      thread2.start();

      System.out.println("Starting thread3...");
      Thread thread3 = new GuessANumber(27);
      thread3.start();
      try {
         thread3.join();
      } catch (InterruptedException e) {
         System.out.println("Thread interrupted.");
      }
      System.out.println("Starting thread4...");
      Thread thread4 = new GuessANumber(75);
      
      thread4.start();
      System.out.println("main() is ending...");
   }
}

Это даст следующий результат. Вы можете попробовать этот пример снова и снова, и каждый раз вы получите другой результат.

Выход

Starting hello thread...
Starting goodbye thread...
Hello
Hello
Hello
Hello
Hello
Hello
Goodbye
Goodbye
Goodbye
Goodbye
Goodbye
.......

Основные многопоточные концепции Java

При многопоточном программировании на Java вам понадобятся следующие концепции:

Что такое синхронизация потоков?

Обработка межпотокового общения

Обработка нити тупиковая

Основные операции с потоками