Многопоточность в JAVA

[Syltan]

package uu;
class MyThread extends Thread {
  int count;
   MyThread() {
    count = 0;
  }

  public void run() {
    System.out.println("MyThread starting.");
    try {
      do {
        Thread.sleep(500);
        System.out.println("In MyThread, count is " + count);
        count++;
      } while (count < 5);
    } catch (InterruptedException exc) {
      System.out.println("MyThread interrupted.");
    }
    System.out.println("MyThread terminating.");
  }
}

public class Main {
  public static void main(String args[]) {
    System.out.println("Main thread starting.");
    MyThread mt = new MyThread();
    mt.start();
    do {
      System.out.println("In main thread.");
      try {
        Thread.sleep(250);
      } catch (InterruptedException exc) {
        System.out.println("Main thread interrupted.");
      }
    } while (mt.count != 5);
    System.out.println("Main thread ending.");
  }
}

1)Скажите пожалуйта, зачем нужно исключение InterruptedException
2)

MyThread mt = new MyThread(); //Это создание объекта  mt класса MyThread 
    mt.start();  //Это запуск метода run

В методе Run описывается сам поток, который будет выполнятся? Именно после строки

mt.start();

мы запускаем сам поток?
3)Каким методом происходит завершение потока или для этого не нужен метод?

[BleStaR]

1) исключение InterruptedException - функция sleep(long mm) выбрасывает исключение, поэтому его надо перехватить, тип выбрасываемого исключения InterruptedException. Можешь просто заменить на Exception.
2)функция start - создает поток и запускает его главную функцию run().
3)поток заканчивает свою работу по завершения функции run(). В твоем случае пока count <5 поток будет работать.

P.S. в этой программе работают два потока 1-ый: главный поток приложения, 2-ой созданный тобой.

[Syltan]

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

package u;
class MyThread1 extends Thread {
  int count1=50;
  int count2=100;
 //выполняеться 2 потока поток метода main и MyThread
  public void run() {
    System.out.println("Запуск потока от класса Thread");
    try {
        int i=10;
        int j=0;
        do {
            System.out.println( "Процес № "+i +"  Процес № " +j);
            i++;
            j++;
            Thread.sleep(250);
        } while ( (i<count1) && (j<count2) );
       
    } catch (InterruptedException exc) {
      System.out.println("Процес прерван.");
    }
  System.out.println("Процес заершился.");
  }
}


//Наследование от интерфейса
class MyThread2 implements Runnable {
  int count;

  MyThread2() {
    count = 0;
  }
  public void run() {
    System.out.println("Запуск потока от интерфейса Runable.");
    try {
      do {
        Thread.sleep(500);
        System.out.println("Процес №" + count);
        count++;
      } while (count < 5);
    } catch (InterruptedException exc) {
      System.out.println("Процес прерван.");
    }
    System.out.println("Процес заершился.");
  }
}

public class Main {
  public static void main(String args[]) {
    //Реализация через интерфейс
    System.out.println("Main thread starting.");
    MyThread1 obj1 = new MyThread1();
    //После вызова метода start() начинаеться выполняться метод run()
    Thread obj11 = new Thread();
    obj1.start();

  


//_____________________________________________________________________
/*MyThread2 объект класса, реализующего интерфейс Runnable.
  Объекты таких классов не являются потоками в чистом виде. Создать поток, использую
  данный объект можно только через конструктор класса Thread - Thread(r Runnable)
 (здесь r = obj2).
*/
   //MyThread2 реализует интерфейс Runnable
    MyThread2 obj2 = new MyThread2();
    //создание потока, который будет запускать нащ раннейбл
    Thread obj22 = new Thread(obj2);
    obj22.start();
   }
}

[BleStaR]

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

[Syltan]

Синхронизация это типа Thread.sleep(250); ?

[BleStaR]

нет... sleep() - это усыпление потока на определенное количество милисекунд.

синхоронизация заключается в том, что подпроцесс(в нашем случае поток) блокирует объект, с которым работает, чтобы другие подпроцессы не могли обратиться к данному объекту, пока блокировка не будет снята.