자바 크기 의 스 레 드 풀 을 어떻게 고정 합 니까?

1.고정 크기 의 스 레 드 풀 안내
스 레 드 탱크 는 프로그램 이 시 작 될 때 사용 할 수 있 는 스 레 드 를 몇 개 만들어 서 거기에 두 고 구체 적 인 작업 을 기다 리 는 것 입 니 다.이 임 무 는 기본적으로 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 DBCP2 스 레 드 탱크 의 파생
잦 은 생 성 스 레 드 대상 과 다 중 스 레 드 간 에 컨 텍스트 전환 을 하 는 것 은 시간 과 자원 을 많이 소모 하기 때문에 JDK 1.5 에서 스 레 드 풀 기술 을 제시 했다.
3 스 레 드 탱크 사용Exector4 스 레 드 탱크 의 생 성
고정 크기 의 스 레 드 탱크 만 들 기(가장 많이 사용 되 는 방법)

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);
이상 은 개인 적 인 경험 이 므 로 여러분 에 게 참고 가 되 기 를 바 랍 니 다.여러분 들 도 저 희 를 많이 응원 해 주시 기 바 랍 니 다.

좋은 웹페이지 즐겨찾기