Связь потоков в Java

Question

Я пытаюсь научиться использовать потоки в Java. В настоящее время я застрял в одном упражнении, где у меня есть три потока A, B и C, каждый с локальным массивом. Я хочу, чтобы три потока обменивались данными друг с другом, чтобы они могли найти минимально возможное число, которое взаимно (пересекается) со всеми локальными массивами. Если есть такой номер, я хочу, чтобы нить B напечатала его и закрыла другие потоки, если такого номера нет, я намерен закрыть программу. Каким может быть возможное решение? Как передать информацию между потоками в этом сценарии? Вот мой код до сих пор:

import java.util.Random; 
import java.util.Arrays; 

public class MyThread implements Runnable { 
    private Thread thrd; 
    private Random randomInteger; 
    private int[] localArray; 

    MyThread(String name, int sizeOfLocalArray) { 
     localArray = new int[sizeOfLocalArray]; 
     randomInteger = new Random(); 

     for (int i = 0; i < localArray.length; i++) { 
      localArray[i] = randomInteger.nextInt(); 
     } 

     Arrays.sort(localArray); 

     thrd = new Thread(this, name); 
     thrd.start(); 
    } 

    @Override 
    public void run() { 
     System.out.println(thrd.getName() + " starting"); 

     for (int number : localArray) { 
      System.out.println(number + ", "); 
     } 
     System.out.println(); 

     System.out.println(thrd.getName() + " terminating"); 
    } 

} 

public class Main { 
    public static void main(String[] args) { 
     MyThread myThread = new MyThread("threadF", 5); 
    }  
} 

Answer 1

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

Class ArrayHolder{ 
    private int[] localArray; 

    public ArrayHolder(){ 
     //initialize vars here 
    } 

    public synchronized int lowerstInterection(int[] intArray){ 
     //write the logic here 
    } 
} 

Теперь, когда вы строите ваши темы, передать его ArrayHolder через конструктор, как так

public class Main { 
    public static void main(String[] args) { 
     ArrayHolder arrayHolder = new ArrayHolder() 
     MyThread myThread = new MyThread("threadF", 5, arrayHolder); 
     MyThread myThread = new MyThread("threadG", 5, arrayHolder); 
     MyThread myThread = new MyThread("threadH", 5, arrayHolder); 
    }  
}