자바 크기 의 스 레 드 풀 을 어떻게 고정 합 니까?
스 레 드 탱크 는 프로그램 이 시 작 될 때 사용 할 수 있 는 스 레 드 를 몇 개 만들어 서 거기에 두 고 구체 적 인 작업 을 기다 리 는 것 입 니 다.이 임 무 는 기본적으로 Runnable 의 실현 류 라 고 할 수 있 기 때문에 시스템 이 매번 스 레 드 를 새로 만 들 고 소각 하 는 비용 을 줄 였 으 나 동시에 이러한 스 레 드 를 유지 하 는 비용 을 늘 렸 습 니 다.그 중에서 취 사 는 구체 적 인 상황 을 보고 결정 합 니 다.
고정 크기 의 스 레 드 탱크 는 시작 할 때 고정 개수 의 스 레 드 를 만들어 서 사용 을 기다 리 는 것 입 니 다.
2.스 레 드 탱크 대상 포장
public class TaskPool{
private final ThreadPoolExecutor executor = (ThreadPoolExecutor)Executors.newFixedThreadPool(9); // 9 , CPU , CPU N+1 , IO 2N+1 , N CPU
protected void shutdown(){
// do something
// , ,
executor.shutdown();
// ,
// executor.shutdownNow();
}
protected void execute(Runnable command){
// do something
//
executor.execute(command);
}
public void status(){
StringBuffer sb = new StringBuffer();
//
sb.append(executor.getActiveCount() + "
");
//
sb.append(executor.getQueue().size() + "
");
//
sb.append(executor.getCompletedTaskCount() + "
");
System.out.println(sb.toString());
// : , ,
}
}
3.스 레 드 풀 사용
public class Launcher{
private TaskPool taskPool = new TaskPool();
public static void main(String[] args){
// 100 ,Runnable Task
Task[] tasks = new Task[100];
for (int i = 0; i < tasks.length; i++){
tasks[i] = new Task("Task " + (i+1));
//
taskPool.execute(task[i]);
if ( i % 50 == 0){
taskPool.status();
}
}
private static class Task implements Runnable{
private String name;
public Task(String name){
this.name = name;
}
public void run(){
// do something
System.out.println(" :" + this.name);
}
}
}
자바 스 레 드 풀 확장스 레 드 탱크 소개
1 상용 연못 화 기술
C3P0
DBCP
2 스 레 드 탱크 의 파생잦 은 생 성 스 레 드 대상 과 다 중 스 레 드 간 에 컨 텍스트 전환 을 하 는 것 은 시간 과 자원 을 많이 소모 하기 때문에 JDK 1.5 에서 스 레 드 풀 기술 을 제시 했다.
3 스 레 드 탱크 사용
Exector
4 스 레 드 탱크 의 생 성고정 크기 의 스 레 드 탱크 만 들 기(가장 많이 사용 되 는 방법)
ExecutorService pool = Executors.newFixedThreadPool(2);
Runnable task = new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName());
}
}
};
pool.execute(task);
pool.execute(task);
pool.execute(task);//
가 변 크기 스 레 드 풀 만 들 기
ExecutorService pool = Executors.newCachedThreadPool();
Runnable task = new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName());
}
}
};
pool.execute(task);
pool.execute(task);
pool.execute(task);
독립 작업 의 스 레 드 풀 만 들 기
ExecutorService pool = Executors.newSingleThreadExecutor();
Runnable task = new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName());
}
}
};
pool.execute(task);
pool.execute(task);
pool.execute(task);
스케줄 러 스 레 드 풀 만 들 기
ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(2);
Runnable task = new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName());
}
}
};
threadPool.schedule(task, 2000, TimeUnit.MILLISECONDS);
이상 은 개인 적 인 경험 이 므 로 여러분 에 게 참고 가 되 기 를 바 랍 니 다.여러분 들 도 저 희 를 많이 응원 해 주시 기 바 랍 니 다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 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에 따라 라이센스가 부여됩니다.