Поток случайных чисел и поток AVG

package com.company;
 
import java.util.OptionalDouble;
import java.util.stream.IntStream;
 
import java.util.Random;
 
public class Main
{
    static int My_Array[];
    static class My_Thread_1 extends Thread
    {
        My_Thread_1(String name)
        {
            super(name);
        }
 
        public void run()
        {
            System.out.printf(Thread.currentThread().getName() + " started!\n");
            try
            {
                Random random = new Random(); My_Array = new int[10];
                for (int i = 0; i < My_Array.length; i++)
                { My_Array[i] = random.nextInt(); }
                for (int i = 0; i < My_Array.length; i++)
                { System.out.print(My_Array[i] + " "); } System.out.print("\n");
 
                Thread.sleep(500);
            }
            catch(InterruptedException e)
            { System.out.println("Thread has been interrupted"); }
            System.out.printf(Thread.currentThread().getName() + " fiished!\n");
        }
    }
 
    static class My_Thread_2 extends Thread
    {
        My_Thread_2(String name)
        {
            super(name);
        }
 
        public void run()
        {
            System.out.printf(Thread.currentThread().getName() + " started!\n");
            try
            {
                double average = 0;
                if (My_Array.length > 0)
                { double sum = 0;
                for (int j = 0; j < My_Array.length; j++) { sum += My_Array[j]; }
                average = sum / My_Array.length; }
                System.out.println(average);
                /*OptionalDouble count = IntStream.of(My_Array).average();
                System.out.println(count);*/
                Thread.sleep(500);
            }
            catch(InterruptedException e)
            { System.out.println("Thread has been interrupted"); }
            System.out.printf(Thread.currentThread().getName() + " fiished!\n");
        }
    }
 
    public static void main(String[] args)
    {
        new My_Thread_1("My_Thread_1").start();
        new My_Thread_2("My_Thread_2").start();
    }
}

package com.company;
 
import java.util.Arrays;
import java.util.stream.IntStream;
 
public class Main
{
    static int My_Array[];
 
    static class My_Array_Thread extends Thread
    {
        public void run()
        {
            try
            {
                My_Array = new int[20];
                for (int i = 0; i < My_Array.length; i++) { My_Array[i] = (int)(Math.random()*11); }
                for (int i = 0; i < My_Array.length; i++) { System.out.print(My_Array[i] + " "); } System.out.print("— массив (диапазон — 0-10)" + "\n");
 
                Thread.sleep(500);
            }
            catch(InterruptedException e)
            {
                System.out.println(e);
            }
        }
    }
 
    static class My_Average_Thread extends Thread
    {
        public void run()
        {
            try
            {
                double avg = Arrays.stream(My_Array).average().orElse(Double.NaN);
                System.out.println(avg + " — среднее арифметическое массива");
 
                Thread.sleep(500);
            }
            catch(InterruptedException e)
            {
                System.out.println(e);
            }
        }
    }
 
    static class My_Sum_Thread extends Thread
    {
        public void run()
        {
            try
            {
                int count = IntStream.of(My_Array).sum();
                System.out.println(count + " — сумма массива");
 
                Thread.sleep(500);
            }
            catch(InterruptedException e)
            {
                System.out.println(e);
            }
        }
    }
 
    public static void main(String[] args) throws InterruptedException
    {
        new My_Array_Thread().start();
        Thread.sleep(1000);
        new My_Average_Thread().start();
        new My_Sum_Thread().start();
    }
}