[Android SDK] [JAVA] THREAD에서 데이터 반환(폴링, 콜백) - RECEIVE DATA BY USING THREAD POLLING, CALLBACK

Thread에서 데이터 반환(폴링, 콜백) - Receive data by using thread polling, callback

 

1. thread의 데이터 반환

- run(), start() 는 어떤 값도 반환하지 않는다. 

- 특정한 방법이 필요하다

 

2. 일반 적인 데이터 반환

1) ThreadTest.java

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

 

public class ThreadTest implements Runnable{

 

private String fileName;

private String result;

 

public ThreadTest(String fileName) {

this.fileName = fileName;

}

 

@Override

public void run() {

 

FileOutputStream out = null;

String filePath = "/Users/jeonghui/eclipse-workspace/JavaTest/src/";

String content = "Hello";

 

try {

out = new FileOutputStream(filePath + fileName);

out.write(content.getBytes());

} catch (IOException e) {

e.printStackTrace();

}finally {

try {

out.close();

//결과 셋

result = fileName;

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

 

}

 

public String getResult() {

return result;

}

 

}

 

 

- getResult() 를 이용하여 파일 쓰기가 끝나면 파일 이름을 반환한다.

2) ThreadInterface.java

import java.io.IOException;

 

public class ThreadInterface {

 

public static void main(String[] args) throws IOException {

 

String[] files = {"abc0.txt","abc1.txt","abc2.txt"};

 

for(String filename : files) {

ThreadTest tt = new ThreadTest(filename);

Thread t = new Thread(tt);

t.start();

 

//결과 출력

System.out.println(tt.getResult());

}

 

}

}

 

 

 

 

- getResult() 를 호출하여 확인한다.

3) 문제

- 그러나 콘솔에는 null 값이 출력되거나 운 좋다면 파일 명이 나올 수 있다.

스레드의 처리 속도와 main() 의 속도가 불일치(경쟁조건) 하다.

 

3.  폴링(polling)을 이용한 경쟁조건 해결

1) 폴링(polling) 이란?

-  동기화를 목적으로 상태를 주기적으로 검사하여 일정 조건이 만족하면 처리하는 방법

2) 위의 문제 해결

import java.io.IOException;

 

public class ThreadInterface {

 

public static void main(String[] args) throws IOException {

 

String[] files = {"abc0.txt","abc1.txt","abc2.txt"};

ThreadTest[] tt = new ThreadTest[files.length];

 

for(int i = 0; i<files.length; i++) {

tt[i] = new ThreadTest(files[i]);

Thread t = new Thread(tt[i]);

t.start();

}

 

for(int i = 0; i<files.length; i++) {

//결과 출력

경축! 아무것도 안하여 에스천사게임즈가 새로운 모습으로 재오픈 하였습니다.
어린이용이며, 설치가 필요없는 브라우저 게임입니다.
https://s1004games.com

while(true) {

if(tt[i].getResult() != null) {

System.out.println(tt[i].getResult());

break;

}

}

 

}

 

}

 

}

 

 

 

- 반복적으로 null 을 체크하여 아니라면 출력한다.

3) 문제

- 체크하기 위하여 너무 많은 일을 한다.

- 메인 스레드가 작업종료 상태를 계속 확인해야 하기 때문에 다른 스레드가 일할 시간 없다(성능저하)

 

4. 콜백(callback) 으로 문제 해결

1) 콜백(callback) 이란?

- 단일 스레드의 작업이 끝났을 때 자신을 생성한 클래스를 호출하여  메인 스레드에게 결과를 알려준다.

- 폴링의 무한 루프로 결과값을 체크하는 문제 해결

1) ThreadTest.java

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

 

public class ThreadTest implements Runnable{

 

private String fileName;

private String result;

 

public ThreadTest(String fileName) {

this.fileName = fileName;

}

 

@Override

public void run() {

 

FileOutputStream out = null;

String filePath = "/Users/jeonghui/eclipse-workspace/JavaTest/src/";

String content = "Hello";

 

try {

out = new FileOutputStream(filePath + fileName);

out.write(content.getBytes());

} catch (IOException e) {

e.printStackTrace();

}finally {

try {

out.close();

//결과 셋

ThreadInterface.ThreadResult(fileName);

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

 

}

 

public String getResult() {

return result;

}

 

 

}

 

 

- 정적 메소드를 호출하여 결과값을 전달한다.

2) ThreadInterface.java

import java.io.IOException;

 

public class ThreadInterface {

 

public static void ThreadResult(String name) {

System.out.println(name);

}

 

public static void main(String[] args) throws IOException {

 

String[] files = {"abc0.txt","abc1.txt","abc2.txt"};

ThreadTest[] tt = new ThreadTest[files.length];

 

for(int i = 0; i<files.length; i++) {

tt[i] = new ThreadTest(files[i]);

Thread t = new Thread(tt[i]);

t.start();

}

}

 

}

 

 

- 반환 값을 받기위한 정적메소드 

3) 개선

- 정적메소드를 호출하는 것보다 인스턴스를 생성하여 반환값을 받는 것이 더 좋다.

4) 문제

스레드의 순서가 없다. 먼저 종료되는 스레드의 결과를 먼저 받는다.

- 순서가 필요한 결과 값이라면 다른 방법이 필요하다.(Future, callable, Executor)

 

[출처] https://heeestorys.tistory.com/978

 

본 웹사이트는 광고를 포함하고 있습니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
번호 제목 글쓴이 날짜 조회 수
161 [Java 자료구조] JPA와 Spring Data JPA의 차이 file 졸리운_곰 2022.09.09 287
160 [java 자료구조] 하이버네이트 쉽게 입문하기 (기초)-환경설정,입력조회 개발 file 졸리운_곰 2022.09.09 251
159 [Java 자료구조] JPA, Hibernate, 그리고 Spring Data JPA의 차이점 졸리운_곰 2022.09.09 303
158 [Java][MyBatisc] myBatis에서 null과 nullString을 체크할 때 졸리운_곰 2021.09.13 242
157 [MongoDB/Java] MongoDB에 JSON 형식 데이터 삽입하기 file 졸리운_곰 2021.07.13 233
156 [Java, MongoDB] mongodb java driver 3.0: how to store JSON document 졸리운_곰 2021.07.13 208
155 [Java 자료구조] [Java] 문자열의 첫 글자 제거 졸리운_곰 2021.05.24 642
154 [Java 자료구조] [java] 특정 문자열 사이의 문자열 추출하기, 정규식 졸리운_곰 2021.05.24 2063
153 [Java 자료구조] [JAVA] Java언어로 JSON 생성, 파싱 예제 file 졸리운_곰 2021.05.17 189
152 [Java 자료구조] [Java] Immutable Class (불변 클래스) file 졸리운_곰 2021.03.07 224
151 [Java 자료구조] 불변 객체란? Java Immutable Object file 졸리운_곰 2021.03.07 185
150 [Java 자료구조] [Java] Immutable Object(불변객체) 졸리운_곰 2021.03.07 260
149 [java 자료구조] Oracle + Mybatis 환경에서의 Date 다루기 졸리운_곰 2021.02.25 235
148 Java JSON library Jackson Date Date Json 시리얼라이즈/디씨리얼라이즈 file 졸리운_곰 2021.02.25 190
147 [Java, JSON, jackson] Ignoring new fields on JSON objects using Jackson 졸리운_곰 2021.02.19 213
146 [Java] [Jackson] JsonInclude 속성에 대해 알아보자. 졸리운_곰 2021.02.03 710
145 [java] [jackson] Map - JSON간 변환 졸리운_곰 2021.02.02 337
144 [java] [자료구조] Remove null values from json using jackson 졸리운_곰 2021.02.02 271
143 자바 인코딩 관련 문제 종합 정리 file 졸리운_곰 2021.01.29 253
142 [Java 디자인패턴] [JAVA 디자인 패턴] static을 응용한 싱글톤 패턴(Singleton Pattern) 구현 졸리운_곰 2021.01.22 158
대표 김성준 주소 : 경기 용인 분당수지 U타워 등록번호 : 142-07-27414
통신판매업 신고 : 제2012-용인수지-0185호 출판업 신고 : 수지구청 제 123호 개인정보보호최고책임자 : 김성준 sjkim70@stechstar.com
대표전화 : 010-4589-2193 [fax] 02-6280-1294 COPYRIGHT(C) stechstar.com ALL RIGHTS RESERVED