I'm trying to use volley to make asynchronous, parallel requests. I know
this should be default behaviour, I can't figure out what I am doing wrong.
I wrote an Instrumentation test to check the asynchronism of the
RequestQueue processing. This should go inside de **androidTest** folder,
it does not assert anything, I'm only using this to check the print()
output :
package com.test.testparallelvolley;
import android.content.Context;
import android.support.test.InstrumentationRegistry;
import android.support.test.runner.AndroidJUnit4;
import com.android.volley.AuthFailureError;
import com.android.volley.NetworkResponse;
import com.android.volley.Request;
import com.android.volley.RequestQueue;
import com.android.volley.Response;
import com.android.volley.VolleyError;
import com.android.volley.toolbox.HttpHeaderParser;
import com.android.volley.toolbox.JsonRequest;
import com.android.volley.toolbox.Volley;
import org.json.JSONArray;
import org.json.JSONException;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
@RunWith(AndroidJUnit4.class)
public class ParallelRequestTest {
private static Context context;
private static RequestQueue mRequestQueue;
public ParallelRequestTest(){
}
@BeforeClass
public static void initilize(){
System.out.println("INITIALIZING");
try {
context = InstrumentationRegistry.getTargetContext();
mRequestQueue = newRequestQueue(context.
getApplicationContext());
}catch(Throwable t){
t.printStackTrace();
}
}
@Test
public void testAsync() throws Exception{
addRequest("A");
addRequest("B");
Thread.sleep(15000);
for(String msg : log){
System.out.println(msg);
}
}
private void addRequest(final String desc) throws AuthFailureError {
String url = "https://api.github.com/users/rails/repos";;
String body = "";
Response.Listener<JSONArray> success = new Response.Listener<
JSONArray>() {
@Override
public void onResponse(JSONArray response) {
log(desc + " success ");
// log(response.toString());
if(desc.equals("A")){
try {
log(desc + " sleeping 10s ");
Thread.sleep(10000);
log(desc + " awake ");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
log(desc + " finish success listener ");
}
};
Response.ErrorListener error = new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
log(desc + " ERROR " + error.getMessage());
error.printStackTrace();
log(desc + " finish failure listener ");
}
};
JsonRequest<JSONArray> req = new JsonRequest<JSONArray>(Request.
Method.GET, url , body, success, error) {
@Override
protected Response<JSONArray> parseNetworkResponse(
NetworkResponse response) {
log(desc + " RESPONSE: " + response.statusCode);
try {
String jsonString = new String(response.data,
HttpHeaderParser.parseCharset(response.
headers));
return Response.success(new JSONArray(jsonString),
HttpHeaderParser.parseCacheHeaders(response
));
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (JSONException e) {
e.printStackTrace();
}
return null;
}
};
mRequestQueue.add(req);
log("ADDED " + desc);
}
public static RequestQueue newRequestQueue(Context context) {
return Volley.newRequestQueue(context);
}
// public static RequestQueue newRequestQueue(Context context) {
// File cacheDir = new File(context.getCacheDir(), "volley");
//
// HttpStack stack = new HurlStack();
//
// ByteArrayPool pool = new ByteArrayPool(65536);
//
// Network network = new BasicNetwork(stack, pool){
// @Override
// public NetworkResponse performRequest(Request<?> request)
throws VolleyError {
// log("PERFORMING REQUEST");
// return super.performRequest(request);
// }
// };
//
// RequestQueue queue = new RequestQueue(new
DiskBasedCache(cacheDir), network, 100);
// queue.start();
//
// return queue;
// }
private static ArrayList<String> log = new ArrayList<>();
private static void log(String message){
log.add(message);
}
}
I have tried running it on an emulator as well as on an actual Smartphone,
the result is the same. The testAsync() method print the following output:
ADDED A
ADDED B
PERFORMING REQUEST
A RESPONSE: 304
A success
{"status":"ok"}
A sleeping 10s
A awake
A finish success listener
PERFORMING REQUEST
B RESPONSE: 304
B success
{"status":"ok"}
B finish success listener
As you can see the requests are being executed synchronously. **Even
weirder, volley is waiting for the reponse listener to return before
executing the second request**.
I also have tried specifying explicitly the size of the Network pool and
number of worker threads - check the commented newRequestQueue() function.
This is the build.gradle file
apply plugin: 'com.android.application'
android {
compileSdkVersion 23
buildToolsVersion "23.0.3"
defaultConfig {
applicationId "com.test.testparallelvolley"
minSdkVersion 15
targetSdkVersion 23
versionCode 1
versionName "1.0"
testInstrumentationRunner
"android.support.test.runner.AndroidJUnitRunner"
}
buildTypes {
release {
minifyEnabled false
proguardFiles getDefaultProguardFile('proguard-android.txt'
), 'proguard-rules.pro'
}
}
}
dependencies {
compile fileTree(dir: 'libs', include: ['*.jar'])
testCompile 'junit:junit:4.12'
compile 'com.android.support:appcompat-v7:23.1.1'
compile "com.android.volley:volley:1.0.0"
androidTestCompile 'com.android.support:support-annotations:23.1.1'
androidTestCompile 'com.android.support.test:rules:0.5'
androidTestCompile 'com.android.support.test:runner:0.5'
}
and the AndroidManifest.xml
<manifest xmlns:android="http://schemas.android.com/apk/res/android";
package="com.test.testparallelvolley">
<uses-permission android:name="android.permission.INTERNET" />
<application
android:allowBackup="true"
android:icon="@mipmap/ic_launcher"
android:label="@string/app_name"
android:supportsRtl="true"
android:theme="@style/AppTheme">
</application>
</manifest>
--
You received this message because you are subscribed to the Google Groups
"Android Developers" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/android-developers.
To view this discussion on the web visit
https://groups.google.com/d/msgid/android-developers/d07ce07d-cc9b-46e6-92de-7a8df3262e5d%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
