스레드

class MyThread extends Thread { public void run() { System.out.println("Thread 실행 중!"); } } public class Main { public static void main(String[] args) { MyThread t = new MyThread(); t.start(); // run() 직접 호출 X } }

class MyRunnable implements Runnable { public void run() { System.out.println("Runnable 실행!"); } } public class Main { public static void main(String[] args) { Thread t = new Thread(new MyRunnable()); t.start(); } }

class Task extends Thread { public void run() { for(int i = 1; i <= 5; i++) { System.out.println(getName() + " → " + i); } } } public class MultiThreadTest { public static void main(String[] args) { new Task().start(); new Task().start(); } }

import java.util.Vector; class VectorExample { public static void main(String[] args) { Vector<Integer> vector = new Vector<>(); // 스레드 1: 요소 추가 Thread t1 = new Thread(() -> { for (int i = 0; i < 1000; i++) { vector.add(i); } }); // 스레드 2: 요소 추가 Thread t2 = new Thread(() -> { for (int i = 1000; i < 2000; i++) { vector.add(i); } }); t1.start(); t2.start(); try { t1.join(); t2.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("Vector 크기: " + vector.size()); // 출력: Vector 크기: 2000 (동기화되어 안전함) } }

import java.util.ArrayList; class ArrayListExample { public static void main(String[] args) { ArrayList<Integer> list = new ArrayList<>(); // 스레드 1: 요소 추가 Thread t1 = new Thread(() -> { for (int i = 0; i < 1000; i++) { list.add(i); } }); // 스레드 2: 요소 추가 Thread t2 = new Thread(() -> { for (int i = 1000; i < 2000; i++) { list.add(i); } }); t1.start(); t2.start(); try { t1.join(); t2.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("ArrayList 크기: " + list.size()); // 출력: ArrayList 크기: 1950 (예시 - 동기화되지 않아 데이터 손실 가능) // 실행할 때마다 결과가 다를 수 있음 } }

import java.util.ArrayList; import java.util.Collections; import java.util.List; class SynchronizedArrayListExample { public static void main(String[] args) { // Collections.synchronizedList()로 동기화된 리스트 생성 List<Integer> syncList = Collections.synchronizedList(new ArrayList<>()); Thread t1 = new Thread(() -> { for (int i = 0; i < 1000; i++) { syncList.add(i); } }); Thread t2 = new Thread(() -> { for (int i = 1000; i < 2000; i++) { syncList.add(i); } }); t1.start(); t2.start(); try { t1.join(); t2.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("동기화된 ArrayList 크기: " + syncList.size()); // 출력: 동기화된 ArrayList 크기: 2000 (안전함) } }

class Counter { private int count = 0; public synchronized void increment() { count++; } public int getCount() { return count; } }

class BankAccount { private int balance = 1000; // 임계 구역: 잔액을 수정하는 메소드 public synchronized void withdraw(int amount) { if (balance >= amount) { balance -= amount; System.out.println("출금: " + amount + ", 잔액: " + balance); } } // 임계 구역: 잔액을 수정하는 메소드 public synchronized void deposit(int amount) { balance += amount; System.out.println("입금: " + amount + ", 잔액: " + balance); } }

class Shared { synchronized void waitExample() throws InterruptedException { System.out.println("대기 중..."); wait(); // 다른 스레드가 notify()할 때까지 대기 System.out.println("깨워짐!"); } synchronized void notifyExample() { notify(); // 하나의 스레드를 깨움 } }

class NotificationExample { private Object lock = new Object(); // 알림을 보내는 스레드 class Notifier extends Thread { public void run() { synchronized (lock) { System.out.println("알림 보내는 중..."); lock.notify(); // 하나의 대기 스레드를 깨움 // lock.notifyAll(); // 모든 대기 스레드를 깨움 } } } // 알림을 기다리는 스레드 class Waiter extends Thread { public void run() { synchronized (lock) { try { System.out.println("알림 대기 중..."); lock.wait(); // 알림을 받을 때까지 대기 System.out.println("알림 받음!"); } catch (InterruptedException e) { e.printStackTrace(); } } } } }

class DataBox { private String data; private boolean empty = true; public synchronized void put(String data) { while (!empty) { try { wait(); } catch (InterruptedException e) {} } this.data = data; empty = false; System.out.println("생산: " + data); notifyAll(); } public synchronized void get() { while (empty) { try { wait(); } catch (InterruptedException e) {} } System.out.println("소비: " + data); empty = true; notifyAll(); } } class Producer extends Thread { private DataBox box; public Producer(DataBox box) { this.box = box; } public void run() { for (int i = 1; i <= 5; i++) box.put("Data-" + i); } } class Consumer extends Thread { private DataBox box; public Consumer(DataBox box) { this.box = box; } public void run() { for (int i = 1; i <= 5; i++) box.get(); } } public class ThreadExample { public static void main(String[] args) { DataBox box = new DataBox(); new Producer(box).start(); new Consumer(box).start(); } }

public class MultiJoinTest extends Thread { long start, end; // 스레드 시작값, 종료값 long sum; // 합계 public MultiJoinTest(long start, long end) { this.start = start; this.end = end; } @Override public void run() { for (long i = start; i <= end ; i++) { sum += i; } } public static void main(String[] args) throws InterruptedException { long totalSum = 1_000_000_000L; // 10억 // 1. 단일 스레드 long startTime = System.currentTimeMillis(); long sumSingle = 0; for (long i = 1; i <= totalSum; i++) { sumSingle += i; } long endTime = System.currentTimeMillis(); System.out.println("단일 스레드 합계 : " + sumSingle); System.out.println("실행 시간(ms) : " + (endTime - startTime)); // 2. 스레드 2개 startTime = System.currentTimeMillis(); MultiJoinTest t1 = new MultiJoinTest(1, totalSum/2); MultiJoinTest t2 = new MultiJoinTest(totalSum/2 + 1, totalSum); t1.start(); t2.start(); t1.join(); // 메인 스레드를 t1 스레드 종료까지 일시정지 t2.join(); // 메인 스레드를 t2 스레드 종료까지 일시정지 // 다시 메인 스레드 시작 long sum2 = t1.sum + t2.sum; endTime = System.currentTimeMillis(); System.out.println("스레드 2개 합계 : " + sum2); System.out.println("실행 시간(ms) : " + (endTime - startTime)); // 3. 스레드 4개 startTime = System.currentTimeMillis(); long part = totalSum / 4; MultiJoinTest s1 = new MultiJoinTest(1, part); MultiJoinTest s2 = new MultiJoinTest(part + 1, part*2); MultiJoinTest s3 = new MultiJoinTest(part*2 + 1, part*3); MultiJoinTest s4 = new MultiJoinTest(part*3 + 1, totalSum); s1.start(); s2.start(); s3.start(); s4.start(); s1.join(); s2.join(); s3.join(); s4.join(); long sum3 = s1.sum + s2.sum + s3.sum + s4.sum; endTime = System.currentTimeMillis(); System.out.println("스레드 4개 합계 : " + sum3); System.out.println("실행 시간(ms) : " + (endTime - startTime)); } }

Platform.runLater(() -> { // UI 업데이트 코드 label.setText("데이터 수신 완료"); });

new Thread(() -> { try (Socket socket = new Socket("localhost", 8080)) { // 소켓 통신 코드 InputStream input = socket.getInputStream(); // 데이터 수신 후 UI 업데이트 Platform.runLater(() -> updateUI(data)); } catch (IOException e) { e.printStackTrace(); } }).start();