자바 스 레 드 탱크 의 거부 정책 이 무엇 입 니까?

거부 정책
(JDK 는 4 가 지 를 제공 하고 거부 정책 도 사용자 정의 할 수 있 기 때문에 총 5 가지 가 있 습 니 다.)
스 레 드 탱크 의 스 레 드 가 이미 다 사용 되 었 습 니 다.새로운 작업 에 서 비 스 를 계속 할 수 없습니다.또한 대기 행렬 도 이미 꽉 차 서 더 이상 새로운 작업 을 할 수 없습니다.이때 우 리 는 전략 체 제 를 거절 하고 이 문 제 를 합 리 적 으로 처리 해 야 한다.
JDK 에 내 장 된 거부 정책 은 다음 과 같 습 니 다.
1.AbortPolicy:이상 을 직접 던 져 시스템 의 정상 적 인 운행 을 막는다.
2.CallerRunsPolicy:스 레 드 탱크 가 닫 히 지 않 으 면 이 정책 은 호출 자 스 레 드 에서 현재 버 려 진 작업 을 직접 실행 합 니 다.분명히 이렇게 하면 정말 임 무 를 버 리 지 않 을 것 이다.그러나 임무 제출 라인 의 성능 은 급 격 히 떨 어 질 가능성 이 높다.
3.DiscardPolicy:이 정책 은 처리 할 수 없 는 임 무 를 묵묵히 버 리 고 처리 하지 않 습 니 다.만약 임 무 를 잃 어 버 리 는 것 을 허락 한다 면,이것 은 가장 좋 은 방안 이다.
4.DiscardOldestPolicy:가장 오래된 요청,즉 실 행 될 작업 을 버 리 고 현재 작업 을 다시 제출 하려 고 합 니 다.
이상 내 장 된 거부 정책 은 모두 Rejected Execution Handler 인 터 페 이 스 를 실 현 했 습 니 다.만약 에 상기 정책 이 실제 수 요 를 만족 시 키 지 못 하면 Rejected Execution Handler 인 터 페 이 스 를 스스로 확장 할 수 있 습 니 다.
1.1 AbortPolicy(기본 거부 정책)
(new Thread PoolExecutor.AbortPolicy()라 는 인자 가 없 을 수도 있 습 니 다.암시 적 인 기본 거부 정책)

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;


public class ThreadDemo58 {
    public static void main(String[] args) {

        //      
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                5, 5,
                0, TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(5),
                new ThreadPoolExecutor.AbortPolicy());
        for (int i = 0; i < 11; i++) {
            int finalI = i;
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println("  ：" + finalI + "，   ：" +
                            Thread.currentThread().getName());
                }
            });
        }
    }
}

1.2 CallerRunsPolicy(스 레 드 탱크 를 호출 하 는 스 레 드 로 작업 을 수행 합 니 다)
(즉,메 인 라인 을 사용 하여 작업 을 수행 합 니 다)

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;


public class ThreadDemo59 {
    public static void main(String[] args) throws InterruptedException {

        //      
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                5, 5,
                0, TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(5),
                new ThreadPoolExecutor.CallerRunsPolicy());
        for (int i = 0; i < 11; i++) {
            int finalI = i;
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println("  ：" + finalI + "，   ：" +
                            Thread.currentThread().getName());
                }
            });
//            Thread.sleep(200);
        }

    }
}

1.3 DiscardPolicy(새 작업 무시)

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;



public class ThreadDemo59 {
    public static void main(String[] args) throws InterruptedException {

        //      
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                5, 5,
                0, TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(5),
                new ThreadPoolExecutor.AbortPolicy());
        for (int i = 0; i < 11; i++) {
            int finalI = i;
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println("  ：" + finalI + "，   ：" +
                            Thread.currentThread().getName());
                }
            });
        }
    }
}

1.4 DiscardOldestPolicy(오래된 작업 무시)
(오래된 임 무 는 첫 번 째 로 차단 대기 열 에 들 어간 것 을 말한다)

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;


public class ThreadDemo59 {
    public static void main(String[] args) throws InterruptedException {

        //      
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                5, 5,
                0, TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(5),
                new ThreadPoolExecutor.DiscardOldestPolicy());
        for (int i = 0; i < 11; i++) {
            int finalI = i;
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println("  ：" + finalI + "，   ：" +
                            Thread.currentThread().getName());
                }
            });
        }
    }
}

1.5 사용자 정의 거부 정책

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;


public class ThreadDemo60 {
    public static void main(String[] args) throws InterruptedException {

        //      
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                5, 5,
                0, TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(5),
                new RejectedExecutionHandler() {
                    @Override
                    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                        //        
                        System.out.println("          ");
                    }
                });
        for (int i = 0; i < 11; i++) {
            int finalI = i;
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println("  ：" + finalI + "，   ：" +
                            Thread.currentThread().getName());
                }
            });
        }
    }
}

스 레 드 탱크 의 거부 정책 이 무엇 인지 자세히 알 아 보 겠 습 니 다.의 글 은 여기까지 소개 되 었 습 니 다.더 많은 관련 스 레 드 풀 의 거부 전략 내용 은 우리 의 이전 글 을 검색 하거나 아래 의 관련 글 을 계속 조회 하 시기 바 랍 니 다.앞으로 우 리 를 많이 지지 해 주시 기 바 랍 니 다!