ゞ沉默是金ゞ

          魚離不開水,但是沒有說不離開哪滴水.
          posts - 98,comments - 104,trackbacks - 0
          Future<?> submit( Runnable r )
          Today in part 4 of the series we will talk about submission of runnable task via executor service. This method can be very beneficial if someone wants to upgrade legacy code from 1.4 to 1.5 onwards.
          As per JAVA version 6.0, ExecutorService Interface has following method -
          Future< ? >  submit( Runnable r ) 
            > Submits a Runnable task for execution and returns a Future representing that task.
            > This method will return NULL on successful completeion of the process, otherwise result will not be null.


          Lets start with Runnable task - As we  know that Runnable interface has following method - public void run()
          So when we say - ExecutorService.submit(Runnable Task) --> It starts a new stack starting with run method of runnable task, but as run method can not return any value so does future object. Due to this reason the signature of submit(Runnable r) is Future< ? >.
          ? --> means anything that extends Object, has no lower limit

          package com.jovialjava.blog.threads;

          import java.util.concurrent.ExecutionException;
          import java.util.concurrent.ExecutorService;
          import java.util.concurrent.Executors;
          import java.util.concurrent.Future;

          public class RunnableExample {
              
              
          private static final ExecutorService executorPool=Executors.newFixedThreadPool(2);
              
              
          public static void main(String[] args) {
                  RunnableTask_1 task_1 
          = new RunnableTask_1();
                  RunnableTask_2 task_2 
          = new RunnableTask_2();
                  
                  
          /**
                   * Submit the first task
                   
          */
                  Future
          <?> fut_1 = executorPool.submit(task_1);
                  Future
          <?> fut_2 = executorPool.submit(task_2);
                  
                  
          try{
                      
          if(fut_1.get() == null){
                          System.out.println(
          "TASK 1 completed SUCCESSFULLY");
                      }
                      
          if(fut_2.get() == null){
                          System.out.println(
          "TASK 2 completed SUCCESSFULLY");
                      }
                  }
          catch(ExecutionException e){            
                      System.out.println(e.getMessage());
                  }
          catch(InterruptedException e){
                      System.out.println(e.getMessage());
                  }
          finally{
                      
          /**====VERY IMPORTANT===
                       * This is required to stop the executor pool to
                       * stop accepting new request.
                       
          */
                      executorPool.shutdown();
                  }

              }

              
              
          /**
               * This task will complete successfully
               
          */
              
          public static class RunnableTask_1 implements Runnable{
                  
          public void run()throws NullPointerException{
                      System.out.println(
          "Hi, Inside Runnable Task 1");            
                  }        

              }
              
              
          /**
               * This task will result in error.
               
          */
              
          public static class RunnableTask_2 implements Runnable{
                  
          public void run()throws NullPointerException{
                      System.out.println(
          "Hi, Inside Runnable Task 2");
                      
          throw new IllegalStateException("Runnable Task Exception");
                  }        

              }
          }
          posted on 2012-08-06 10:33 ゞ沉默是金ゞ 閱讀(774) 評論(0)  編輯  收藏 所屬分類: Java SE
          主站蜘蛛池模板: 诸城市| 长治市| 雅安市| 盐源县| 秦皇岛市| 五家渠市| 中西区| 龙里县| 剑河县| 老河口市| 抚州市| 东宁县| 偏关县| 定边县| 林州市| 获嘉县| 阿克陶县| 靖西县| 休宁县| 曲阳县| 兴宁市| 报价| 亳州市| 永靖县| 青阳县| 天峨县| 永宁县| 吴桥县| 大余县| 永胜县| 呈贡县| 西乡县| 宕昌县| 嘉义县| 大关县| 巴塘县| 西青区| 澄城县| 涪陵区| 天门市| 黑龙江省|