欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

AsyncTask异步任务

程序员文章站 2024-01-28 09:39:28
...

实现异步任务的方法:
1.定义一个类,继承AsyncTask,同时声明三个泛型
public class MyTask extends AsyncTask<Params,Progress,Result>
没有返回类型:Void
第一个泛型:子线程执行任务的请求参数类型
第二个泛型:子线程执行任务的进度
第三个泛型:子线程执行任务的返回结果类型
2.重写核心的方法(4个)

  • onPreExecute()
    运行在主线程中,负责初始化的工作
  • doInBackground(Params...)
    运行在子线程中,执行耗时操作
  • onProgressUpdate(Progress...)
    运行在主线程中,实时更新进度条
  • onPostExecute(Result)
    运行在主线程中,更新UI(在doInBackground()方法执行后由系统自动调用)

3.启动异步任务(必须在主线程中启动)
new MyTask().execute(Params... params)
4.在主线程中取消异步任务
myTask.cancel(true)

实例:(通过异步任务在线解析json数据+ProgressBar)

 /**
 *解析json
 */
public class ParseJson {
public static List<String> parseJson(String jsonStr) throws JSONException {
    // TODO Auto-generated method stub
 List<String> data=new ArrayList<String>();
    if (jsonStr!=null) {
    JSONObject object=new JSONObject(jsonStr);
    JSONArray array=object.getJSONArray("items");
    for(int i=0;i<array.length();i++){
        JSONObject object2=array.getJSONObject(i);
        String content=object2.getString("content");
        data.add(content);
    }
}
    return data;
}
}

异步操作:

public class MainActivity extends Activity {
private ProgressBar pb;
private Button btn1,btn2;
private Spinner sp;
private String path="http://m2.qiushibaike.com/article/list/suggest?page=1";
private MyTask task;
@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    pb=(ProgressBar) findViewById(R.id.prog);
    sp=(Spinner) findViewById(R.id.spinner);
}
public void show(View v){
switch (v.getId()) {
case R.id.start:
    //开启异步任务  下载内容
    task=new MyTask();
    task.execute(path);
    
    break;

case R.id.stop:
    //停止异步任务
    task.cancel(true);
    break;
}
}
public class MyTask extends AsyncTask<String, Integer,List<String>>{
 @Override
protected void onPreExecute() {
// TODO Auto-generated method stub
super.onPreExecute();
pb.setVisibility(View.VISIBLE);
//当前进度值=0
pb.setProgress(0);

}
@Override
protected List<String> doInBackground(String... params) {
    // TODO Auto-generated method stub
    
    try {
        //向网络获取数据
        URL url=new URL(params[0]);
        HttpURLConnection connection=(HttpURLConnection) url.openConnection();
        connection.setRequestMethod("GET");
        //请求数据时不能以压缩方式返回
        connection.setRequestProperty("Accept-Encoding","identity");
        if (connection.getResponseCode()==200) {
        InputStream is=connection.getInputStream();
        //得到数据的总长度
        long maxLen=connection.getContentLength();
        //得到数据的当前的加载长度
        long curLen=0;
        //读取数据
        byte[] buffer=new byte[1024];
        int len=0;
        StringBuilder sBuilder=new StringBuilder();
        while ((len=is.read(buffer))!=-1) {
            sBuilder.append(new String(buffer,0,len));
            //计算出当前加载的进度值
            //int pb=(int)(当前加载的长度*100/总长度 ) 百分比
            curLen+=len;
            int progress=(int)(curLen*100/maxLen);
            //更新进度条 异步更新进度条(onProgressUpdata(Integer...values))
            publishProgress(progress);      
          Thread.sleep(1000);
        }
        //解析json数据 List<String>
        return ParseJson.parseJson(sBuilder.toString());
        }
    } catch (Exception e) {
        // TODO: handle exception
    }
    
    return null;
}
    @Override
    protected void onProgressUpdate(Integer... values) {
        // TODO 实时更新进度条
        super.onProgressUpdate(values);
        pb.setProgress(values[0]);
        
    }
   @Override
protected void onPostExecute(List<String> result) {
    // TODO Auto-generated method stub
    super.onPostExecute(result);
    //让进度条消失
    pb.setVisibility(View.GONE);
    if (result!=null&& result.size()>0) {
        ArrayAdapter<String> adapter =new ArrayAdapter<String>(MainActivity.this,android.R.layout.simple_spinner_item,result);
        sp.setAdapter(adapter);
    }else {
        Toast.makeText(MainActivity.this,"获取失败", Toast.LENGTH_SHORT).show();
    }
    
    //通过适配器 将获取到的数据填充到Spinner中
}   
}
   
}