Java 동시 프로그래밍 예(10): 스레드 그룹
Java는 스레드 그룹을 제어하기 위해 ThreadGroup 클래스를 제공합니다.하나의 스레드 그룹은 스레드 대상을 통해 만들 수도 있고, 다른 스레드 그룹으로 만들 수도 있으며, 트리 구조의 스레드를 생성할 수도 있다.
Effective Java의 지침에 따라 ThreadGroup 사용을 권장하지 않습니다.Executor를 사용하는 것이 좋습니다.
D과고는 특별히 이렇게 설명했다.
이 절에서, 우리는 간단한 예시를 개발하기 위해ThreadGroup을 사용합니다.우리는 휴면 시간이 같지 않은 10개의 라인 (예를 들어 아날로그 검색) 을 만들 것입니다. 그 중 하나가 완성되면 나머지 라인을 중단합니다.
그 사실을 알다
아래와 같은 절차에 따라 예시 코드를 완성하세요.
1. 첫 번째 작업을 완료한 스레드의 이름을 저장하기 위한 Result라는 클래스를 만듭니다.String 형식의 개인 변수,name를 설명하고 Setter/Getter 방법을 생성합니다.코드는 다음과 같습니다.
public class Result {
private String name;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
public class SearchTask implements Runnable {
private Result result;
public SearchTask(Result result) {
this.result = result;
}
@Override
public void run() {
String name = Thread.currentThread().getName();
System.out.printf("Thread %s: Start
", name);
try {
doTask();
result.setName(name);
} catch (InterruptedException e) {
System.out.printf("Thread %s: Interrupted
", name);
return;
}
System.out.printf("Thread %s: End
", name);
}
//
private void doTask() throws InterruptedException {
Random random = new Random(new Date().getTime());
int value = (int) (random.nextDouble() * 100);
System.out.printf("Thread %s: %d
",
Thread.currentThread().getName(), value);
TimeUnit.SECONDS.sleep(value);
}
public class Main {
public static void main(String[] args) {
ThreadGroup threadGroup = new ThreadGroup("Searcher");
Result result = new Result();
SearchTask searchTask = new SearchTask(result);
for (int i = 0; i < 5; i++) {
Thread thread = new Thread(threadGroup, searchTask);
thread.start();
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.printf("Number of Threads: %d
", threadGroup.activeCount());
System.out.println("Information about the Thread Group");
threadGroup.list();
Thread[] threads = new Thread[threadGroup.activeCount()];
threadGroup.enumerate(threads);
for (int i = 0; i < threadGroup.activeCount(); i++) {
System.out.printf("Thread %s: %s
", threads[i].getName(),
threads[i].getState());
}
waitFinish(threadGroup);
threadGroup.interrupt();
//
private static void waitFinish(ThreadGroup threadGroup) {
while (threadGroup.activeCount() > 9) {
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
그 까닭을 알다
다음은 프로그램이 실행한 결과입니다.list () 방법의 출력, 각 라인의 상태 등을 볼 수 있습니다.
Thread Thread-0: Start
Thread Thread-0: 52
Thread Thread-1: Start
Thread Thread-1: 41
Thread Thread-2: Start
Thread Thread-2: 69
Thread Thread-3: Start
Thread Thread-3: 60
Thread Thread-4: Start
Thread Thread-4: 88
Number of Threads: 5
Information about the Thread Group
java.lang.ThreadGroup[name=Searcher,maxpri=10]
Thread[Thread-0,5,Searcher]
Thread[Thread-1,5,Searcher]
Thread[Thread-2,5,Searcher]
Thread[Thread-3,5,Searcher]
Thread[Thread-4,5,Searcher]
Thread Thread-0: TIMED_WAITING
Thread Thread-1: TIMED_WAITING
Thread Thread-2: TIMED_WAITING
Thread Thread-3: TIMED_WAITING
Thread Thread-4: TIMED_WAITING
Thread Thread-1: Interrupted
Thread Thread-4: Interrupted
Thread Thread-2: Interrupted
Thread Thread-0: Interrupted
Thread Thread-3: Interrupted
영원히 끝이 없다
Thread Group 클래스에는 여러 가지 방법이 있습니다.API 문서를 검토하여 전체 메소드 설명을 확인하십시오.
나래주의
본고는 《Java7 Concurrency Cookbook》(D 오이고에서 《Java7 병발 예시집》으로 번역)에서 번역한 것으로 학습 자료로만 사용된다.권한이 없으면 어떠한 상업 행위에도 사용할 수 없다.
소소하다
다음은 이 절의 예시에 사용된 코드의 전체 버전이다.
Result 클래스의 전체 코드:
package com.diguage.books.concurrencycookbook.chapter1.recipe10;
/**
*
* Date: 2013-09-30
* Time: 00:45
*/
public class Result {
private String name;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
package com.diguage.books.concurrencycookbook.chapter1.recipe10;
import java.util.Date;
import java.util.Random;
import java.util.concurrent.TimeUnit;
/**
*
* Date: 2013-10-02
* Time: 22:38
*/
public class SearchTask implements Runnable {
private Result result;
public SearchTask(Result result) {
this.result = result;
}
@Override
public void run() {
String name = Thread.currentThread().getName();
System.out.printf("Thread %s: Start
", name);
try {
doTask();
result.setName(name);
} catch (InterruptedException e) {
System.out.printf("Thread %s: Interrupted
", name);
return;
}
System.out.printf("Thread %s: End
", name);
}
//
private void doTask() throws InterruptedException {
Random random = new Random(new Date().getTime());
int value = (int) (random.nextDouble() * 100);
System.out.printf("Thread %s: %d
",
Thread.currentThread().getName(), value);
TimeUnit.SECONDS.sleep(value);
}
}
package com.diguage.books.concurrencycookbook.chapter1.recipe10;
import java.util.concurrent.TimeUnit;
/**
*
* Date: 2013-10-02
* Time: 22:45
*/
public class Main {
public static void main(String[] args) {
ThreadGroup threadGroup = new ThreadGroup("Searcher");
Result result = new Result();
SearchTask searchTask = new SearchTask(result);
for (int i = 0; i < 5; i++) {
Thread thread = new Thread(threadGroup, searchTask);
thread.start();
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.printf("Number of Threads: %d
", threadGroup.activeCount());
System.out.println("Information about the Thread Group");
threadGroup.list();
Thread[] threads = new Thread[threadGroup.activeCount()];
threadGroup.enumerate(threads);
for (int i = 0; i < threadGroup.activeCount(); i++) {
System.out.printf("Thread %s: %s
", threads[i].getName(),
threads[i].getState());
}
waitFinish(threadGroup);
threadGroup.interrupt();
}
//
private static void waitFinish(ThreadGroup threadGroup) {
while (threadGroup.activeCount() > 9) {
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
JPA + QueryDSL 계층형 댓글, 대댓글 구현(2)이번엔 전편에 이어서 계층형 댓글, 대댓글을 다시 리팩토링해볼 예정이다. 이전 게시글에서는 계층형 댓글, 대댓글을 구현은 되었지만 N+1 문제가 있었다. 이번에는 그 N+1 문제를 해결해 볼 것이다. 위의 로직은 이...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
