Java多线程——<八>多线程其他概念

public class TaskSleepingTask extends Task{
    @Override
    public void run() {
        try{
            while(countDown-- > 0){
                System.out.println(status());
                /*
                 * 每个打印之后，每个线程都要睡眠（即阻塞），这使得线程调度器可以切换到另一个线程，进而驱动另一个任务
                 */
                TimeUnit.MICROSECONDS.sleep(100000);
            }    
        /*
         * 因为异常不能跨线程传回给main，所以你必须在线程里处理该异常
         */
        }catch(InterruptedException e){
            System.out.println();
        }
    }
    public static void main(String[] args){
        ExecutorService exec = Executors.newCachedThreadPool();
        for(int i = 0 ; i < 5 ; i++){
            exec.execute(new TaskSleepingTask());
        }
        exec.shutdown();
    }
}

public class TaskPriority implements Runnable{
    private int countDown = 5;
    /*
     * 变量d用来确保不进行任何编译器优化
     */
    @SuppressWarnings("unused")
    private volatile double d;//no optimization
    private int priority;
    public TaskPriority(int priority){
        this.priority = priority;
    }
    /*
     * 打印线程的名称、线程的优先级以及线程所属的“线程组”
     *在线程内部，通过调用Thread.currentThread()来获得对驱动该任务的Thread对象的引用
     */
    public String toString(){
        return Thread.currentThread()+":"+countDown;
    }
    @Override
    public void run() {
        /*
         * 优先级应该在run的开头部分设定，在构造器中设置他们不会有任何好处，因为Executor在此刻还没有开始执行任务
         */
        Thread.currentThread().setPriority(priority);
        /*
         * 执行了10000次浮点运算，数学 运算是可以中断的，这里运算时间足够长，
         * 因此线程调度机制才来得及介入，交换任务并关注优先级，使得最高优先级的线程被优先选择
         */
        while(true){
            for(int i = 1 ;i < 10000;i++){
                d+=(Math.PI + Math.E)/(double)i;
                if(i%1000==0)
                    Thread.yield();
                System.out.println(this);
                if(--countDown == 0 ) 
                    return;
            }
        }
    }
    public static void main(String[] args){
        ExecutorService exec = Executors.newCachedThreadPool();
        for(int i = 0 ; i < 5;i++){
            exec.execute(new TaskPriority(Thread.MIN_PRIORITY));//1
        }
        exec.execute(new TaskPriority(Thread.MAX_PRIORITY));//10
        exec.shutdown();
    }
}