submit java-advanced-ru/sync-primitives

.current.json

@@ -1 +1 @@
-{"assignment":"java-advanced-ru/multithreading-java"}
+{"assignment":"java-advanced-ru/sync-primitives"}

java-advanced-ru/sync-primitives/.gitignore

@@ -1,4 +1,4 @@
-.gradle/
-build/
-caches/
-.idea/
+.gradle/
+build/
+caches/
+.idea/

java-advanced-ru/sync-primitives/src/main/java/exercise/App.java

@@ -1,22 +1,22 @@
-package exercise;
-
-class App {
-
-    public static void main(String[] args) {
-        // BEGIN
-        var list = new SafetyList();
-        var thread1 = new ListThread(list);
-        var thread2 = new ListThread(list);
-        thread1.start();
-        thread2.start();
-        try {
-            thread1.join();
-            thread2.join();
-        } catch (InterruptedException e) {
-            throw new RuntimeException(e);
-        }
-        System.out.println(list.getSize());
-        // END
-    }
-}
-
+package exercise;
+
+class App {
+
+    public static void main(String[] args) {
+        // BEGIN
+        var list = new SafetyList();
+        var thread1 = new ListThread(list);
+        var thread2 = new ListThread(list);
+        thread1.start();
+        thread2.start();
+        try {
+            thread1.join();
+            thread2.join();
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+        System.out.println(list.getSize());
+        // END
+    }
+}
+

java-advanced-ru/sync-primitives/src/main/java/exercise/ListThread.java

@@ -1,22 +1,22 @@
-package exercise;
-
-// BEGIN
-public class ListThread extends Thread {
-    SafetyList list;
-    public ListThread(SafetyList list) {
-        this.list = list;
-    }
-
-    @Override
-    public void run() {
-        for (int i = 0; i < 1000; i++){
-            try {
-                Thread.sleep(1);
-            } catch (InterruptedException e) {
-                throw new RuntimeException(e);
-            }
-            list.add((int) (Math.random() * 1000));
-        }
-    }
-}
-// END
+package exercise;
+
+// BEGIN
+public class ListThread extends Thread {
+    SafetyList list;
+    public ListThread(SafetyList list) {
+        this.list = list;
+    }
+
+    @Override
+    public void run() {
+        for (int i = 0; i < 1000; i++){
+            try {
+                Thread.sleep(1);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+            list.add((int) (Math.random() * 1000));
+        }
+    }
+}
+// END

java-advanced-ru/sync-primitives/src/main/java/exercise/SafetyList.java

@@ -1,26 +1,26 @@
-package exercise;
-
-class SafetyList {
-    // BEGIN
-    int[] array;
-    int size;
-
-    SafetyList() {
-        array = new int[2100];
-        size = 0;
-    }
-
-    synchronized void add(int number) {
-        array[size] = number;
-        size++;
-    }
-
-    public int get(int index) {
-        return index > size ? 0 : array[index];
-    }
-
-    public int getSize() {
-        return this.size;
-    }
-    // END
-}
+package exercise;
+
+class SafetyList {
+    // BEGIN
+    int[] array;
+    int size;
+
+    SafetyList() {
+        array = new int[2100];
+        size = 0;
+    }
+
+    synchronized void add(int number) {
+        array[size] = number;
+        size++;
+    }
+
+    public int get(int index) {
+        return index > size ? 0 : array[index];
+    }
+
+    public int getSize() {
+        return this.size;
+    }
+    // END
+}