Android异步(AsyncTask)并行(executeOnExecutor)|Android异步(AsyncTask)并行(executeOnExecutor) ping-ip
主要代码：
先敲下黑板
*：executeOnExecutor：并行执行，任务可以同步进行。
【Android异步(AsyncTask)并行(executeOnExecutor)|Android异步(AsyncTask)并行(executeOnExecutor) ping-ip】*：execute：串行的即必须等第一个下载完成后才能下载第二个。
我做的项目觉得一个个出来太慢了，所以从串行改为了并行（之前不知道区别，泪目）
private AsyncTask asyncTask;
private int mathTime;
private void pingTime(ChangeServerBean server) {
asyncTask = new AsyncTask() {
@Override
protected String doInBackground(String... strings) {
try {
PingNetEntity pingNetEntity = new PingNetEntity(server.getIp(), 1, 5, new StringBuffer());
pingNetEntity = PingNet.ping(pingNetEntity);
if (pingNetEntity.getPingTime() != null) {
String time = pingNetEntity.getPingTime();
String subTime = time.substring(0, time.length() - 3);
//取整，不保留小数点
mathTime = Math.round(Float.parseFloat(subTime));
}
} catch (Exception e) {}
return String.valueOf(mathTime);
}@Override
protected void onPostExecute(String s) {
server.setDelayTime(Integer.parseInt(s));
if (changeServerAdapter != null) {
changeServerAdapter.notifyDataSetChanged();
}
super.onPostExecute(s);
}
}.executeOnExecutor(ThreadUtil.getThreadPoolExecutor(), server.getIp());
}使用executeOnExecutor(Executor exec,Params... params)里面需要传入一个线程池。我们创建线程池可以创建一个无界线程池。
public class ThreadUtil {private static ThreadPoolExecutor threadPoolExecutor;
/**
* 获取线程池单例
*/public static ThreadPoolExecutor getThreadPoolExecutor() {
if (threadPoolExecutor == null) {
synchronized (ThreadUtil.class) {
if (threadPoolExecutor == null) {
//创建无界线程池，可以进行自动线程回收
threadPoolExecutor = (ThreadPoolExecutor) Executors.newCachedThreadPool();
}
}
}
return threadPoolExecutor;
}}ping-ip的工具类和实体类
public class PingNet {
private static final String TAG = "PingNet";
/**
* @param pingNetEntity 检测网络实体类
* @return 检测后的数据
*/
public static PingNetEntity ping(PingNetEntity pingNetEntity) {
String line = null;
Process process = null;
BufferedReader successReader = null;
String command = "ping -c " + pingNetEntity.getPingCount() + " -w " + pingNetEntity.getPingWtime() + " " + pingNetEntity.getIp();
//String command = "ping -c " + pingCount + " " + host;
try {
process = Runtime.getRuntime().exec(command);
if (process == null) {
Log.e(TAG, "ping fail:process is null.");
append(pingNetEntity.getResultBuffer(), "ping fail:process is null.");
pingNetEntity.setPingTime(null);
pingNetEntity.setResult(false);
return pingNetEntity;
}
successReader = new BufferedReader(new InputStreamReader(process.getInputStream()));
while ((line = successReader.readLine()) != null) {
Log.i(TAG, line);
append(pingNetEntity.getResultBuffer(), line);
String time;
if ((time = getTime(line)) != null) {
pingNetEntity.setPingTime(time);
}
}
int status = process.waitFor();
if (status == 0) {
Log.i(TAG, "exec cmd success:" + command);
append(pingNetEntity.getResultBuffer(), "exec cmd success:" + command);
pingNetEntity.setResult(true);
} else {
Log.e(TAG, "exec cmd fail.");
append(pingNetEntity.getResultBuffer(), "exec cmd fail.");
pingNetEntity.setPingTime(null);
pingNetEntity.setResult(false);
}
Log.i(TAG, "exec finished.");
append(pingNetEntity.getResultBuffer(), "exec finished.");
} catch (IOException e) {
Log.e(TAG, String.valueOf(e));
} catch (InterruptedException e) {
Log.e(TAG, String.valueOf(e));
} finally {
Log.i(TAG, "ping exit.");
if (process != null) {
process.destroy();
}
if (successReader != null) {
try {
successReader.close();
} catch (IOException e) {
Log.e(TAG, String.valueOf(e));
}
}
}
Log.i(TAG, pingNetEntity.getResultBuffer().toString());
return pingNetEntity;
}private static void append(StringBuffer stringBuffer, String text) {
if (stringBuffer != null) {
stringBuffer.append(text + "\n");
}
}private static String getTime(String line) {
String[] lines = line.split("\n");
String time = null;
for (String l : lines) {
if (!l.contains("time="))
continue;
int index = l.indexOf("time=");
time = l.substring(index + "time=".length());
Log.i(TAG, time);
}
return time;
}
}public class PingNetEntity {
/*
TODO：进行ping操作的ip
*/
private String ip;
/*
TODO：进行ping操作的次数
*/
private int pingCount;
/*
TODO：ping操作超时时间
*/private int pingWtime;
/*
TODO：存储ping操作后得到的数据
*/
private StringBuffer resultBuffer;
/*
TODO：ping ip花费的时间
*/
private String pingTime;
/*
TODO：进行ping操作后的结果
*/
private boolean result;
public PingNetEntity(String ip, int pingCount, int pingWtime, StringBuffer resultBuffer) {
this.ip = ip;
this.pingWtime = pingWtime;
this.pingCount = pingCount;
this.resultBuffer = resultBuffer;
}public String getPingTime() {
return pingTime;
}public void setPingTime(String pingTime) {
this.pingTime = pingTime;
}public StringBuffer getResultBuffer() {
return resultBuffer;
}public void setResultBuffer(StringBuffer resultBuffer) {
this.resultBuffer = resultBuffer;
}public int getPingCount() {
return pingCount;
}public void setPingCount(int pingCount) {
this.pingCount = pingCount;
}public String getIp() {
return ip;
}public void setIp(String ip) {
this.ip = ip;
}public boolean isResult() {
return result;
}public void setResult(boolean result) {
this.result = result;
}public int getPingWtime() {
return pingWtime;
}public void setPingWtime(int pingWtime) {
this.pingWtime = pingWtime;
}
}
我项目里的实体类就不写出来了，你自己自定义。。。ping几次视自己情况而定。
推荐阅读
- android第三方框架（五）ButterKnife
- Android中的AES加密-下
- 带有Hilt的Android上的依赖注入
- android|android studio中ndk的使用
- Android事件传递源码分析
- RxJava|RxJava 在Android项目中的使用（一）
- Android7.0|Android7.0 第三方应用无法访问私有库
- 深入理解|深入理解 Android 9.0 Crash 机制（二）
- android防止连续点击的简单实现（kotlin）
- Android|Android install 多个设备时指定设备