接上文

前文中的遗留问题

对于Java多线程的理解。我曾经只局限于实现Runnable接口或者继承Thread类，然后重写run()方法，最后start()调用就算完事。可是一旦涉及死锁以及对共享资源的訪问和随时监控线程的状态和运行顺序和线程返回值等就不行了。

Callable 和 Future 简单介绍

Callable接口代表一段能够调用并返回结果的代码;Future接口表示是运行异步任务时的状态、返回值等信息。所以说Callable用于产生结果，Future用于获取结果。

1. Callable

Callable 是一个接口，它仅仅包括一个call()方法。Callable是一个返回结果而且可能抛出异常的任务。

为了便于理解，我们能够将Callable比作一个Runnable接口，而Callable的call()方法则类似于Runnable的run()方法。

Callable的源代码例如以下：

<span style="font-size:18px;">publi cinterface Callable<V> {
    V call() throws Exception;
}</span>

2. Future

Future 是一个接口。它用于表示异步计算的结果。提供了检查计算是否完毕的方法，以等待计算的完毕，并获取计算的结果。

Future的源代码例如以下：

<span style="font-size:18px;">public interface Future<V> {
    // 试图取消对此任务的运行。
    boolean     cancel(boolean mayInterruptIfRunning)
//假设在任务正常完毕前将其取消，则返回 true。
    boolean     isCancelled()
//假设任务已完毕，则返回 true。
    boolean     isDone()
//如有必要，等待计算完毕，然后获取其结果。

    V           get() throws InterruptedException,ExecutionException;
//如有必要，最多等待为使计算完毕所给定的时间之后，获取其结果（假设结果可用）。
    V             get(long timeout, TimeUnitunit)
          throws InterruptedException,ExecutionException, TimeoutException;
}</span>

演示样例的Callable和Future的基本使用方法

我们先通过一个演示样例看看Callable和Future的基本使用方法

<span style="font-size:18px;">importjava.util.concurrent.Callable;
importjava.util.concurrent.Future;
importjava.util.concurrent.Executors;
importjava.util.concurrent.ExecutorService;
importjava.util.concurrent.ExecutionException;
 
classMyCallable implements Callable {
 
    @Override
    public Integer call() throws Exception {
        int sum    = 0;
        // 运行任务
        for (int i=0; i<100; i++)
            sum += i;
        //return sum;
        return Integer.valueOf(sum);
    }
}
 
publicclass CallableTest1 {
 
    public static void main(String[] args)
        throws ExecutionException,InterruptedException{
        //创建一个线程池
        ExecutorService pool =Executors.newSingleThreadExecutor();
        //创建有返回值的任务
        Callable c1 = new MyCallable();
        //运行任务并获取Future对象
        Future f1 = pool.submit(c1);
        // 输出结果
        System.out.println(f1.get());
        //关闭线程池
        pool.shutdown();
    }
}</span>

执行结果：

4950

结果说明：

在主线程main中，通过newSingleThreadExecutor()新建一个线程池。接着创建Callable对象c1。然后再通过pool.submit(c1)将c1提交到线程池中进行处理。而且将返回的结果保存到Future对象f1中。

然后，我们通过f1.get()获取Callable中保存的结果；最后通过pool.shutdown()关闭线程池。

回到主题：调用查询手机号归属地的webservice

事实上通过上面的简单样例，全然能够将通过Runnable接口或者Thread类实现的线程代码，改动成Callable和Future实现的线程。

<span style="font-size:18px;">public class Main Activity extends Activity { 
 
    public static final String TAG ="webService_pj";
   
    private EditText phoneSecEditText; 
    private TextView resultView; 
    private Button queryButton; 
 
    @Override 
    public void onCreate(BundlesavedInstanceState) { 
           
//           StrictMode.setThreadPolicy(newStrictMode.ThreadPolicy.Builder()
//       .detectDiskReads().detectDiskWrites().detectNetwork()
//        .penaltyLog().build());
//           
//    StrictMode.setVmPolicy(newStrictMode.VmPolicy.Builder()
//       .detectLeakedSqlLiteObjects().penaltyLog().penaltyDeath()
//        .build());
   
       super.onCreate(savedInstanceState); 
       setContentView(R.layout.activity_main); 
 
        phoneSecEditText = (EditText)findViewById(R.id.phone_sec); 
        resultView = (TextView)findViewById(R.id.result_text); 
        queryButton = (Button)findViewById(R.id.query_btn); 
 
        queryButton.setOnClickListener(newOnClickListener() { 
            @Override 
            public void onClick(View v) { 
         
                   Log.i(TAG,"MainActivity线程ID："+Thread.currentThread().getId());
 
                // 手机号码（段） 
                String phoneSec =phoneSecEditText.getText().toString().trim(); 
                // 简单推断用户输入的手机号码（段）是否合法 
                if("".equals(phoneSec) || phoneSec.length() < 7) { 
                    // 给出错误提示 
                   phoneSecEditText.setError("您输入的手机号码（段）有误。"); 
                   phoneSecEditText.requestFocus(); 
                    // 将显示查询结果的TextView清空 
                   resultView.setText(""); 
                    return; 
                } 
               
                // 命名空间 
                String nameSpace = "http://WebXml.com.cn/"; 
                // 调用的方法名称 
                String methodName ="getMobileCodeInfo"; 
                // EndPoint 
                String endPoint = "http://webservice.webxml.com.cn/WebServices/MobileCodeWS.asmx"; 
                // SOAP Action 
                String soapAction = "http://WebXml.com.cn/getMobileCodeInfo";
                // method params and values
                ArrayList<String> params= new ArrayList<String>();
                ArrayList<Object> vals =new ArrayList<Object>();
               params.add("mobileCode");
                params.add("userId");
                vals.add(phoneSec);
                vals.add("");
               
               
                //通过Callable和Future创建线程。调用WebService
//创建有返回值的任务
                CallableThread callable = newCallableThread(nameSpace,methodName,endPoint,soapAction,params,vals);
              // 创建一个线程池
                   ExecutorServiceexecutor=Executors.newCachedThreadPool(); 
                   
                     //运行任务并获取Future对象
                   Future<String>future = executor.submit(callable);
               
                try {
//输出结果
resultView.setText(future.get());
 
 //关闭线程池
executor.shutdown();
}catch (InterruptedException e) {
e.printStackTrace();
}catch (ExecutionException e) {
e.printStackTrace();
}
               
            } 
        }); 
    } 
 
 
    private class CallableThread implementsCallable<String> { 
        private String nameSpace;
        private String methodName;
        private String endPoint;
        private String soapAction;
        private ArrayList<String> params;
        private ArrayList<Object> vals;
 
        public CallableThread(StringnameSpace,  String methodName,
                       StringendPoint, String soapAction, ArrayList<String> params,ArrayList<Object> vals){ 
            this.nameSpace = nameSpace;
            this.methodName = methodName;
            this.endPoint = endPoint;
            this.soapAction = soapAction;
            this.params = params;
            this.vals = vals;
        } 
       
        //须要实现Callable的Call方法 
        public String call() throws Exception{ 
// 这种方法的实现见上篇文章或者源代码
          return getRemoteInfo(nameSpace,methodName, endPoint,
                                soapAction,params,vals);
        } 
    } </span>

至此，Android调用Webservice就完美的完毕了。

源代码下载

http://download.csdn.net/detail/tcl_6666/7365341