Java 동시 프로그래밍 예(二): 스레드 정보 가져오기 및 설정
ID: 이 속성은 각 스레드의 고유 ID를 나타냅니다.
Name: 이 속성은 각 스레드의 이름을 저장합니다.
Priority: 이 속성은 각 Thread 객체의 우선 순위를 저장합니다.스레드 우선 순위는 1부터 110개 단계로 나뉘는데 1은 최저 우선 순위, 10은 최고 우선 순위를 나타낸다.라인을 수정하는 우선순위는 추천하지 않지만, 이 방면의 수요가 있다면 시도해 볼 수도 있다.
Status: 이 속성은 스레드의 상태를 저장합니다.새 (new), 실행 (runnable), 차단 (blocked), 대기 (waiting), 시간 제한 대기 (time waiting) 또는 종료 (terminated) 등 6가지 다른 상태가 있습니다.라인의 상태는 반드시 그 중의 하나이다.
이 소절에서, 우리는 프로그램에 10개의 라인을 새로 만들고, 모든 라인의 이름과 우선순위를 설정하는 프로그램을 개발할 것이다.그리고 라인을 실행하고 라인의 상태 정보를 관찰하며 라인의 실행이 끝날 때까지 합니다.다시 한 번 설명하자면, 이 노선들은 여전히 하나의 수를 계산하는 곱셈표이다.
그 사실을 알다
다음 절차에 따라 이 예제를 수행합니다.
1. Runnable 인터페이스를 실현하기 위해 Calculator라는 클래스를 만듭니다.코드는 다음과 같습니다.
public class Calculator implements Runnable {
private int number;
public Calculator(int number) {
this.number = number;
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
System.out.printf("%s: %d * %d = %d
",
Thread.currentThread().getName(),
number, i, i * number);
}
}
public class Main {
public static void main(String[] args) {
Thread[] threads = new Thread[10];
Thread.State[] status = new Thread.State[threads.length];
for (int i = 0; i < threads.length; i++) {
threads[i] = new Thread(new Calculator(i));
if ((i % 2) == 0) {
threads[i].setPriority(Thread.MAX_PRIORITY);
} else {
threads[i].setPriority(Thread.MIN_PRIORITY);
}
threads[i].setName("Thread-" + i);
}
try (FileWriter file = new FileWriter("D:\\thread.log");
PrintWriter pw = new PrintWriter(file)) {
8. 모든 스레드의 상태를 파일에 기록합니다.현재 상태는 새로 만들기(NEW)일 것입니다.코드는 다음과 같습니다.
for (int i = 0; i < threads.length; i++) {
Thread thread = threads[i];
pw.println("Main: Status of Thread " + i +
" : " + threads[i].getState());
status[i] = threads[i].getState();
}
for (int i = 0; i < threads.length; i++) {
threads[i].start();
}
boolean finish = false;
while (!finish) {
for (int i = 0; i < threads.length; i++) {
if (threads[i].getState() != status[i]) {
writeThreadInfo(pw, threads[i], status[i]);
status[i] = threads[i].getState();
}
}
finish = true;
for (int i = 0; i < threads.length; i++) {
finish = finish
&& (threads[i].getState() == Thread.State.TERMINATED);
}
}
/**
* 。
*
* @param pw PrintWriter
* @param thread
* @param state
*/
private static void writeThreadInfo(PrintWriter pw,
Thread thread, Thread.State state) {
pw.printf("Main : Id %d = %s
", thread.getId(), thread.getName());
pw.printf("Main : Priority: %d
", thread.getPriority());
pw.printf("Main : Old State: %s
", state);
pw.printf("Main : New State: %s
", thread.getState());
pw.printf("Main : ********************************
");
}
그 까닭을 알다
다음은 thread입니다.log 파일의 내용 세션입니다.파일 내용을 보면 높은 우선순위의 라인이 낮은 우선순위의 라인보다 대체적으로 실행을 빨리 끝낸다는 것을 알 수 있다.또한 각 라인의 상태 진화 과정도 볼 수 있다.
Main : ********************************
Main : Id 11 = Thread-2
Main : Priority: 10
Main : Old State: BLOCKED
Main : New State: TERMINATED
Main : ********************************
Main : Id 13 = Thread-4
Main : Priority: 10
Main : Old State: BLOCKED
Main : New State: TERMINATED
Main : ********************************
Main : Id 14 = Thread-5
Main : Priority: 1
Main : Old State: BLOCKED
Main : New State: TERMINATED
Main : ********************************
Thread-8: 8 * 2 = 16
Thread-8: 8 * 3 = 24
Thread-8: 8 * 4 = 32
Thread-6: 6 * 0 = 0
Thread-6: 6 * 1 = 6
Thread-6: 6 * 2 = 12
Thread-6: 6 * 3 = 18
Thread-6: 6 * 4 = 24
Thread-6: 6 * 5 = 30
Thread-6: 6 * 6 = 36
Thread-6: 6 * 7 = 42
Thread-6: 6 * 8 = 48
Thread-6: 6 * 9 = 54
Thread-5: 5 * 0 = 0
Thread-5: 5 * 1 = 5
Thread-5: 5 * 2 = 10
Thread-5: 5 * 3 = 15
Thread-5: 5 * 4 = 20
스레드의 이름을 설정하지 않으면 Java 가상 기회에서 이 형식을 사용할 때 이름을 지정합니다. thread-XX입니다. 그 중에서 XX는 숫자입니다.우리는 스레드의 ID와 스레드의 상태를 수정할 수 없습니다.Thread 클래스도 이러한 수정을 허용하기 위해 setId () 와 setStatus () 방법을 실현하지 않았습니다.
영원히 끝이 없다
이 섹션에서는 스레드 정보에 액세스하기 위해 Thread 객체를 사용하는 방법을 학습했습니다.사실, Runnable의 실현 클래스도 우리가 이 정보에 접근하는 것을 실행한다.Thread 클래스의 정적 방법currentThread () 는 실행 중인 Runnable 구현 클래스의 대상을 가져와 라인에 접근할 수 있습니다.
주의해야 할 것은 1 ~ 10 이외의 우선순위를 설정하려고 하면 setPriority () 에서 IllegalArgumentException 이라는 예외가 발생합니다.
나래주의
본고는 《Java7 Concurrency Cookbook》(D 오이고에서 《Java7 병발 예시집》으로 번역)에서 번역한 것으로 학습 자료로만 사용된다.권한이 없으면 어떠한 상업 행위에도 사용할 수 없다.
소소하다
Calculator 클래스의 전체 코드
package com.diguage.books.concurrencycookbook.chapter1.recipe2;
/**
* Date: 2013-09-13
* Time: 19:49
*/
public class Calculator implements Runnable {
private int number;
public Calculator(int number) {
this.number = number;
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
System.out.printf("%s: %d * %d = %d
",
Thread.currentThread().getName(),
number, i, i * number);
}
}
}
package com.diguage.books.concurrencycookbook.chapter1.recipe2;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
/**
* Date: 2013-09-13
* Time: 19:51
*/
public class Main {
public static void main(String[] args) {
Thread[] threads = new Thread[10];
Thread.State[] status = new Thread.State[threads.length];
for (int i = 0; i < threads.length; i++) {
threads[i] = new Thread(new Calculator(i));
if ((i % 2) == 0) {
threads[i].setPriority(Thread.MAX_PRIORITY);
} else {
threads[i].setPriority(Thread.MIN_PRIORITY);
}
threads[i].setName("Thread-" + i);
}
try (FileWriter file = new FileWriter("D:\\thread.log");
PrintWriter pw = new PrintWriter(file)) {
for (int i = 0; i < threads.length; i++) {
Thread thread = threads[i];
pw.println("Main: Status of Thread " + i +
" : " + threads[i].getState());
status[i] = threads[i].getState();
}
for (int i = 0; i < threads.length; i++) {
threads[i].start();
}
boolean finish = false;
while (!finish) {
for (int i = 0; i < threads.length; i++) {
if (threads[i].getState() != status[i]) {
writeThreadInfo(pw, threads[i], status[i]);
status[i] = threads[i].getState();
}
}
finish = true;
for (int i = 0; i < threads.length; i++) {
finish = finish
&& (threads[i].getState() == Thread.State.TERMINATED);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 。
*
* @param pw PrintWriter
* @param thread
* @param state
*/
private static void writeThreadInfo(PrintWriter pw,
Thread thread, Thread.State state) {
pw.printf("Main : Id %d = %s
",
thread.getId(), thread.getName());
pw.printf("Main : Priority: %d
", thread.getPriority());
pw.printf("Main : Old State: %s
", state);
pw.printf("Main : New State: %s
", thread.getState());
pw.printf("Main : ********************************
");
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 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에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
