多线程数据传递用法总结
本文参考: 李宁- Java多线程初学者指南(7):向线程传递数据的三种方法
大纲:
- Java多线程间数据传递的三种方式
1.1 通过构造方法传递数据
1.2 通过变量和方法传递数据
1.3 通过回调函数传递数据 - Android多线程数据传递
2.1 AsyncTask
2.2 Hander
扩展阅读
一、Java - 向线程传递数据
一般线程在使用时,都需要预先传入一些数据,比如网络请求的网址,读取的文件路径等等
1.通过构造函数传递参数
这种方式是在创建线程对象的同时传递数据,保证了在thread.start()前获得到数据;如果想要传递更复杂的数据,可以使用集合、类等数据结构,如果数据比较多的时候,可以考虑使用第二种方法
线程类
public class mianThread extends Thread {
private String mcontent;
public mianThread(String content) {
this.mcontent = content;
}
public void run() {
System.out.println(mcontent);
}
}
主函数
public class mian {
public static void main(String[] args) {
mianThread m = new mianThread("0611");
m.start();
}
}
2. 通过变量和方法传递参数
向对象传递参数,一般有两种方式,一种是通过构造函数,另一种是通过setXXXX()方式,对对象进行赋值
线程类
public class mianThread extends Thread {
private int mdata;
private String mcontent;
public void setContent(String content) {
this.mcontent = content;
}
public void setData(int data) {
this.mdata = data;
}
public void run() {
System.out.println("时间:" + mdata + mcontent);
}
}
主函数
public class mian {
public static void main(String[] args) {
mianThread m = new mianThread();
m.setContent("今天沈阳暴雨");
m.setData(20160611);
m.start();
}
3. 通过回调函数传递数据
暂略
二、Android 线程间传递数据
1.AsyncTask
class DownloadTask extends AsyncTask<Params,Progress,Result>{}
新建一个子类继承自AsyncTask,三个参数:
params:在执行AsyncTask时要传进去的参数
Progress:用于publishProgress(line)和onProgressUpdate()间传递参数的类型
Resule: 任务执行完毕后,返回结果的类型
实例:
效果
class DownloadTask extends AsyncTask<TextView,String,Boolean>{
TextView mtv;
//第一个执行的方法,运行在主线程中,用于完成一些界面初始化的操作
@Override
protected void onPreExecute() {
tv.setText("即将开始下载");
for (int i = 0;i < 10000;i++){
//延时
}
}
//子线程中执行,如果在此处需要更新UI操作,需调用publishProgress(line)方法将要传递的参
// 数,传递到onProgressUpdate()方法中
@Override
protected Boolean doInBackground(TextView... params) {
mtv = params[0];
StringBuilder content = null;
try {
URL url = new URL("https://bao.wallstreetcn.com/q/quote/v1/real?" +
"en_prod_code=002234.SZ,002299.SZ,002458.SZ,&fields=prod_name,px_change_rate,");
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);
conn.setReadTimeout(5000);
if (conn.getResponseCode() == 200) {
InputStream in = conn.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
String line = "";
content = new StringBuilder();
while ((line = reader.readLine()) != null) {
content.append(line);
publishProgress(line);
}
}
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
if(content != null){
return true;
}else {
return false;
}
}
//调用publishProgress()方法后,该方法会很快执行,利用方法中携带的参数进行对界面进行刷新
@Override
protected void onProgressUpdate(String... values) {
for(int i = 0;i<values.length;i++){
mtv.setText(values[i]);
}
}
//后台任务执行完毕后,可以通过此方法进行提示
@Override
protected void onPostExecute(Boolean aBoolean) {
Toast.makeText(MainActivity.this, "下载成功了", Toast.LENGTH_SHORT).show();
}
2. Handler
2.1 消息队列
注意:创建Message对象时,Message msg = Message.obtain(); 如果消息池中有Message,则取出,如果没有在重新创建,避免重复创建,浪费资源。
2.2 Runnable队列
Handler对象维护一个线程队列,有新的Runnable送来(post())的时候,把它放在队尾,而处理 Runnable的时候,从队头取出Runnable执行。当向队列发送一个Runnable后,立即就返回,并不理会Runnable是否被执行,执行 是否成功等。而具体的执行则是当排队排到该Runnable后系统拿来执行的。
具体操作
向队列添加线程:
- handler.post(Runnable runnable) 直接将runnable对象添加到队列中
- handler。postDelayed(Runnable runnable,Long time) 延迟一段时间,再将其添加到队列中
- handler.postAtTime(Runnable runnable,Long time);定时将其添加到队列中去
- 结束线程:handler.removeCallbacks(thread); 将runnable对象从队列中取出
实例:每隔2秒钟打印一下
Runnable runnable = new Runnable() {
@Override
public void run() {
Log.e("——————————————","今天是六月十二号,阅览室又碰到了那个菇凉~");
handler.postDelayed(this,2000);
}
};handler.postDelayed(runnable,2000);