Java에서 스레드를 생성하는 방법 요약-Java시작하기-php.cn

Java에서 스레드를 생성하는 방법 요약

王林

풀어 주다： 2020-01-08 16:59:06

앞으로

2182명이 탐색했습니다.

Java에서 스레드를 생성하는 방법 요약

1. Thread 클래스 상속

public class ThreadCreator extends Thread{

    public static void main(String[] args) {
       //第一种方式：
       ThreadCreator creator = new ThreadCreator();
       Thread thread = new Thread(creator,"线程1");
       thread.start();
       //第二种方式：
       Thread thread = new ThreadCreator();
       thread.start();
       //第三种方式：
       new ThreadCreator().start();
　　　}
 
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "run");
    }
}

로그인 후 복사

2. Runnable 인터페이스 구현

(무료 학습 동영상 튜토리얼 공유: java 동영상 튜토리얼)

public class ThreadCreator implements Runnable{

    public static void main(String[] args) {
       ThreadCreator creator = new ThreadCreator();
       Thread thread = new Thread(creator,"线程1");
       thread.start();
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "run");
    }
}

로그인 후 복사

3. ExecutorService

public class ThreadCreator implements Callable<Integer> {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
       ThreadCreator creator = new ThreadCreator();
       FutureTask futureTask = new FutureTask(creator);
       Thread thread = new Thread(futureTask,"线程");
       thread.start();
       System.out.println(futureTask.get());
    }

    @Override
    public Integer call() {
        return 1024;
    }
}

로그인 후 복사

스레드 풀에서 제출과 실행의 차이점:

(1) 허용되는 작업 유형은 다릅니다. 실행은 실행 가능한 작업만 허용하고 제출은 호출 가능한 작업도 허용합니다.

(2) 반환 값: 실행에는 반환 값이 없습니다. 작업이 제출되면 현재 스레드에서 실행 결과를 모니터링할 수 없습니다. Submit에는 반환 값을 받거나 예외에 응답하는 데 사용되는 Future 유형 반환 값이 있습니다. get() 메소드를 통해 획득됩니다.

제출의 맨 아래 레이어는 여전히 실행이라고 불리지만 이를 기반으로 미래 레이어로 캡슐화되며 실행 중에 생성된 모든 예외는 변수에 캡슐화됩니다.

public class ThreadCreator{

   static ExecutorService service = Executors.newFixedThreadPool(5);

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        //execute无返回值
        service.execute(new ThreadTask(1,"1"));
        //submit有返回值
        Future<Integer> result = service.submit(new ThreadTaskCall());
        System.out.println(result.get());
        service.shutdownNow();
    }
    static class ThreadTask implements Runnable{
        private int param1;
        private String param2;
        public ThreadTask(int param3,String param4){
            this.param1 = param3;
            this.param2 = param4;
        }
        @Override
        public void run() {
            System.out.println(param1+param2);
        }
    }

    static class ThreadTaskCall implements Callable<Integer>{
        @Override
        public Integer call() throws Exception {
            return 1024;
        }
    }
}

로그인 후 복사

또한 Spring의 일정 주석은 다음을 사용합니다. 처리 방법을 참조하십시오.

5. 익명 내부 클래스

public void run() {
        if (state != NEW ||
            !UNSAFE.compareAndSwapObject(this, runnerOffset,
                                         null, Thread.currentThread()))
            return;
        try {
            Callable<V> c = callable;
            if (c != null && state == NEW) {
                V result;
                boolean ran;
                try {
                    result = c.call();
                    ran = true;
                } catch (Throwable ex) {
                    result = null;
                    ran = false;
                    setException(ex);
                }
                if (ran)
                    set(result);
            }
        } finally {
            runner = null;
            int s = state;
            if (s >= INTERRUPTING)
                handlePossibleCancellationInterrupt(s);
        }
    }
protected void setException(Throwable t) {
        if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
            outcome = t;
            UNSAFE.putOrderedInt(this, stateOffset, EXCEPTIONAL); // final state
            finishCompletion();
        }
    }

로그인 후 복사

lambda 스레드 풀:

public class ThreadCreator {

    public static void main(String[] args) {

        //继承Thread类
        new Thread() {
            @Override
            public void run() {
                System.out.println("extends Thread Class!");
            }
        }.start();
        //实现Runnable接口
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("implement Runnable!");
            }
        }).start();
        //实现Callable接口
        new Thread(new FutureTask<Integer>(new Callable() {
            @Override
            public Integer call() throws Exception {
                return 1024;
            }
        })).start();
        //lambda表达式
        new Thread(() -> System.out.println("execute single code")).start();
        new Thread(() -> {
            System.out.println("execute multiple code");
        }).start();
    }
}

로그인 후 복사