Concurrency/Client.java at master · apwinter2020/Concurrency · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
public class Client {

    public static void main(String[] args) throws InterruptedException {
        int n = 20000000;

        int sum = 0;
        for (int i = 0; i < n; i++) {
            if(Prime.isPrime(i)){
                sum++;
            }
        }

        System.out.println(sum);

        int totalCore = 10;

        Prime.totalCore = totalCore;
        Prime.n = n;

        Prime[] primeArray = new Prime[totalCore];

        for (int i = 0; i < totalCore; i++) {
            primeArray[i] = new Prime(i);
            primeArray[i].start();
        }

        boolean flag = true;
        while(flag) {
            flag = false;
            for (int i = 0; i < totalCore; i++) {
                if (primeArray[i].isAlive()){
                    flag = true;
                }
            }
        }

        int sum2 = 0;
        for (int i = 0; i < totalCore; i++) {
            sum2 += primeArray[i].primeAmount;
        }
        System.out.println(sum2);
#
//        MyThread t1 = new MyThread("1");
//        t1.start();
//        MyThread t2 = new MyThread("2");
//        t2.start();
//
//        while (t1.isAlive() || t2.isAlive()){
//        }
//
//        System.out.println(MyThread.number);
//
//        Thread t3 = new Thread(new MyRunnable());
//        t3.start();

    }

}

class Prime extends Thread{
    static int totalCore;
    static int n;

    int name;
    int primeAmount;

    public Prime(int name) {
        this.name = name;
    }

    @Override
    public void run() {
        for (int i = name; i < n; i+=totalCore) {
            if(isPrime(i)){
                primeAmount++;
            }
        }
    }

    public static boolean isPrime(int number){
        boolean flag = true;
        if(number == 1){
            return false;
        }
        if(number == 2){
            return true;
        }

        for (int i = 2; i < Math.sqrt(number) + 1; i++) {
            if(number % i == 0){
                flag = false;
                break;
            }
        }
        return flag;
    }
}


class MyThread extends Thread{
    static int number;
    String name;

    public MyThread(String name) {
        this.name = name;
    }

    @Override
    public void run() {
        for (int i = 0; i < 10000; i++) {
            number++;
            super.run();
        }
    }
}

class MyRunnable implements Runnable{

    @Override
    public void run() {
        System.out.println("Hello");
    }
}