Asynctask异步处理类的使用
2016-05-18 12:04
363 查看
主类
线程类
package com.example.day08_asynctask;
import java.io.BufferedReader;
import java.io.IOException;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import android.os.AsyncTask;
import android.os.SystemClock;
import android.widget.ProgressBar;
import android.widget.TextView;
// 三个参数,1.线程执行前传入的数据类型 params 2.线程中更新的数据类型 3.线程执行后的结果类型
public class MyAsynctask extends AsyncTask<String, Integer, String> {
TextView tv;
ProgressBar pb;
String path = "";
private BufferedReader br;
private StringBuffer sb;
private String str;
public MyAsynctask(TextView tv, ProgressBar pb) {
super();
this.tv = tv;
this.pb = pb;
}
// 开启后台线程
@Override
protected String doInBackground(String... params) {
System.out.println("正式开启线程,得到传来的数据" + params[0]);
HttpClient httpClient = new DefaultHttpClient();
HttpGet httpGet = new HttpGet(params[0]);
try {
HttpResponse httpResponse = httpClient.execute(httpGet);
if (httpResponse.getStatusLine().getStatusCode() == 200) {
HttpEntity entity = httpResponse.getEntity();
str = EntityUtils.toString(entity);
for (Integer i = 0; i < 100; i++) {
SystemClock.sleep(200);
publishProgress(i);
}
}
} catch (ClientProtocolException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return str;
}
// 开始后台线程前执行
@Override
protected void onPreExecute() {
System.out.println("准备开启线程");
super.onPreExecute();
}
@Override
protected void onPostExecute(String result) {
System.out.println("子类线程得到结果数据:" + result);
tv.setText("任务类设置的信息" + str);
super.onPostExecute(result);
}
@Override
protected void onProgressUpdate(Integer... values) {
System.out.println("线程执行中得到传来的数据" + values[0]);
tv.setText(values[0] + "%");
super.onProgressUpdate(values);
}
}
package com.example.day08_asynctask; import java.util.concurrent.ExecutionException; import android.os.Bundle; import android.R.integer; import android.app.Activity; import android.view.Menu; import android.widget.ProgressBar; import android.widget.TextView; public class MainActivity extends Activity { TextView tv; TextView tv2; ProgressBar pb; String key = "3ac9f31ff66b9746539472887b3799c3"; // 通过get请求时的接口地址 String get_path = "http://web.juhe.cn:8080/constellation/getAll?consName=狮子座&type=today&key=" + key; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); tv = (TextView) findViewById(R.id.textView1); tv2 = (TextView) findViewById(R.id.textView2); pb = (ProgressBar) findViewById(R.id.progressBar1); // 主页提供控件,和联网地址 System.out.println("new 出对象"); MyAsynctask myAsynctask = new MyAsynctask(tv, pb); System.out.println("执行extcte方法"); // 执行完,这里先得到执行的结果,类中在得到 myAsynctask.execute(get_path); try { String string = myAsynctask.get(); System.out.println("主线程得到线程结束的数据:" + string); tv2.setText("主线程的设置" + string); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } }
线程类
package com.example.day08_asynctask;
import java.io.BufferedReader;
import java.io.IOException;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import android.os.AsyncTask;
import android.os.SystemClock;
import android.widget.ProgressBar;
import android.widget.TextView;
// 三个参数,1.线程执行前传入的数据类型 params 2.线程中更新的数据类型 3.线程执行后的结果类型
public class MyAsynctask extends AsyncTask<String, Integer, String> {
TextView tv;
ProgressBar pb;
String path = "";
private BufferedReader br;
private StringBuffer sb;
private String str;
public MyAsynctask(TextView tv, ProgressBar pb) {
super();
this.tv = tv;
this.pb = pb;
}
// 开启后台线程
@Override
protected String doInBackground(String... params) {
System.out.println("正式开启线程,得到传来的数据" + params[0]);
HttpClient httpClient = new DefaultHttpClient();
HttpGet httpGet = new HttpGet(params[0]);
try {
HttpResponse httpResponse = httpClient.execute(httpGet);
if (httpResponse.getStatusLine().getStatusCode() == 200) {
HttpEntity entity = httpResponse.getEntity();
str = EntityUtils.toString(entity);
for (Integer i = 0; i < 100; i++) {
SystemClock.sleep(200);
publishProgress(i);
}
}
} catch (ClientProtocolException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return str;
}
// 开始后台线程前执行
@Override
protected void onPreExecute() {
System.out.println("准备开启线程");
super.onPreExecute();
}
@Override
protected void onPostExecute(String result) {
System.out.println("子类线程得到结果数据:" + result);
tv.setText("任务类设置的信息" + str);
super.onPostExecute(result);
}
@Override
protected void onProgressUpdate(Integer... values) {
System.out.println("线程执行中得到传来的数据" + values[0]);
tv.setText(values[0] + "%");
super.onProgressUpdate(values);
}
}
相关文章推荐
- Andorid Launcher程序代码分析
- Messenger实现Android IPC
- 用ActionBar+Fragment实现Tab分类列表
- android gralloc 流程分析
- Android帧缓冲区(Frame Buffer)硬件抽象层(HAL)模块Gralloc的实现原理分析
- ListView子控件抢占焦点的问题
- 一个监听器绑定多个按钮控件
- Android API Level
- AlertDialog类的使用
- 在onTabSelected里面调用viewPager.setCurrentItem方法发生java.lang.NullPointerException错误
- Unity java C 互调
- Github官方app分析——用户身份验证模块
- android下文件访问权限及修改
- Andorid Unable to execute dex: Multiple dex files define Lorg/apache/commons/collections/Buffer
- Application did not close the cursor or database object that was opened here 异常
- The connection to adb is down, and a severe error has occured.
- Andorid开发第一个程序HelloWorld
- handler机制的原理
- React Native官方实例UIExplorer项目(for android)运行遇到的问题
- 关于Retrofit 2.0的使用