너T야? 나 T(story)야….

InputStream, OutputStream

현대의 컴퓨터는 대부분 byte 단위로 데이터를 주고 받는다. 참고로 bit 단위는 너무 작기 때문에 byte 단위를 기본으로 사용한다. 자바 내부에 있는 데이터를 외부에 있는 파일에 저장하거나, 네트워크를 통해 전송하거나 콘솔에 출력할 때 모두 byte 단위로 데이터를 주고 받는다. 스트림을 사용하면 파일을 사용하든, 소켓을 통해 네트워크를 사용하든 모두 일관된 방식으로 데이터를 주고 받을 수 있다. 그리고 수 많은 기본 구현 클래스들도 제공한다. InputStream, OutputStream 이 다양한 스트림들을 추상화하고 기본 기능에 대한 표준을 잡아둔 덕분에 개발자는 편리하게 입출력 작업을 수행할 수 있다. 이러한 추상화의 장점은 다음과 같다.일관성 : 모든 종류의 입출력 작업에 대해 동일한 인터..

백준 2667 - Java

import java.util.*;public class BJ2667 { static int N; static int[][] map; static boolean[][] visited; static int[][] d = {{0, -1},{0, 1},{-1, 0},{1, 0}}; static List complexSizes; public static void main(String[] args) { insert(); bfs(); printf(); } public static void insert() { Scanner sc = new Scanner(System.in); N = sc.nextInt(); ..

스레드 풀과 Executor 프레임워크 - 2

ExecutorService 우아한 종료서비스를 안정적으로 종료하는 것도 매우 중요하다. 이렇게 문제 없이 우아하게 종료하는 방식을 graceful shutdown 이라 한다.  서비스 종료void shutdown()새로운 작업을 받지 않고, 이미 제출된 작업을 모두 완료한 후에 종료한다.논 블로킹 메서드(이 메서드를 호출한 스레드는 대기하지 않고 즉시 다음 코드를 호출한다.) List shutdownNow()실행 중인 작업을 중단하고, 대기 중인 작업을 반환하며 즉시 종료한다.실행 중인 작업을 중단하기 위해 인터럽트를 발생시킨다.논 블로킹 메서드 서비스 상태 확인boolean isShutdown(): 서비스가 종료되었는지 확인한다.boolean isTerminated(): shutdown(), shut..

스레드 풀과 Executor 프레임워크

스레드를 직접 사용할 때의 문제점스레드 생성 시간으로 인한 성능 문제스레드 관리 문제Runnable 인터페이스의 불편함 1. 스레드 생성 비용으로 인한 성능 문제스레드를 사용하려면 먼저 스레드를 생성해야 한다. 그런데 스레드는 다음과 같은 이유로 매우 무겁다. 메모리 할당 : 각 스레드는 자신만의 호출 스택(call stack)을 가지고 있어야 한다. 이 호출 스택은 스레드가 실행되는 동안 사용하는 메모리 공간이다. 따라서 스레드를 생성할 때는 이 호출 스택을 위한 메모리를 할당해야 한다. 운영체제 자원 사용 : 스레드를 생성하는 작업은 운영체제 커널 수준에서 이루어지며, 시스템 콜(system call)을 통해 처리된다. 이는 CPU와 메모리 리소스를 소모하는 작업이다. 운영체제 스케줄러 설정 : 새로..

원자적 연산

원자적 연산 (atomic operation)의 의미는 해당 연산이 더 이상 나눌 수 없는 단위로 수행된다는 것을 의미한다. 즉, 원자적 연산은 중단되지 않고, 다른 연산과 간섭 없이 완전히 실행되거나 전혀 실행되지 않는 성질을 가지고 있다. 쉽게 이야기해서 멀티스레드 상황에서 다른 스레드의 간섭 없이 안전하게 처리되는 연산이라는 뜻이다. 성질을 가지고 있다. 쉽게 이야기해서 멀티스레드 상황에서 다른 스레드의 간섭 없이 안전하게 처리되는 연산이라는 뜻 synchronized 블록이나 Lock 등을 사용해서 안전한 임계 영역을 만들어야 한다. public interface IncrementInteger { void increment(); int get();}public class BasicInt..

public interface BoundedQueue { void put(String data); String take();} BoundedQueue: 버퍼 역할을 하는 큐의 인터페이스이다.put(data) : 버퍼에 데이터를 보관한다. (생산자 스레드가 호출하고, 데이터를 생산한다.)take(): 버퍼에 보관된 값을 가져간다. (소비자 스레드가 호출하고, 데이터를 소비한다.) import java.util.ArrayDeque;import java.util.Queue;import static util.MyLogger.log;public class BoundedQueueV implements BoundedQueue{ private final Queue queue = new Array..

synchronized 단점무한 대기 :  BLOCKED 상태의 스레드는 락이 풀릴 때 까지 무한 대기한다.특정 시간까지만 대기하는 타임아웃X중간에 인터럽트X공정성: : 락이 돌아왔을 때 BLOCKED 상태의 여러 스레드 중에 어떤 스레드가 락을 획득할 지 알 수 없다. 최악의 경우 특정 스레드가 너무 오랜기간 락을 획득하지 못할 수 있다. LockSupport 를 사용하면 synchronized 의 가장 큰 단점인 무한 대기 문제를 해결할 수 있다.  LockSupport 는 스레드를 WAITING로 변경하는데 WAITING이란 상태는 누가 깨워주기 전까지는 계속 대기한다. 그리고 CPU 실행 스케줄링에 들어가지 않는다.park() : : 스레드를 WAITING 상태로 변경한다.parkNanos(nan..

import java.util.LinkedList;import java.util.Queue;import java.util.Scanner;public class BJ1697 { public static void main(String[] args) { Scanner sc = new Scanner(System.in); int N = sc.nextInt(); int K = sc.nextInt(); boolean[] visited = new boolean[100001]; Queue queue = new LinkedList(); queue.add(new int[]{N, 0}); visited[N] = true; ..

멀티스레드를 사용할 때 가장 주의해야 할 점은, 같은 자원(리소스)에 여러 스레드가 동시에 접근할 때 발생하는 동시성 문제이다. 참고로 여러 스레드가 접근하는 자원을 공유 자원이라고 한다. 대표적인 공유 자원은 인스턴스의 필드(멤버 변수)이다. 멀티스레드를 사용할 때는 이런 공유 자원에 대한 접근을 적절하게 동기화(synchronization)해서 동시성 문제가 발생하지 않게 방지하는 것이 중요하다. import static util.MyLogger.log;import static util.ThreadUtils.sleep;public class BankMain { public static void main(String[] args) throws InterruptedException { ..

import static util.MyLogger.log;import static util.ThreadUtils.sleep;public class VolatileFlagMain { public static void main(String[] args) { MyTask task = new MyTask(); Thread t = new Thread(task,"work"); log("runFlag = "+task.runFlag); t.start(); sleep(1000); log("runFlag = false 로 변경 시도"); task.runFlag = false; log("runFlag = " + task..