jeena/essayist
1
0
Fork 0
Code Issues Pull requests Projects Packages Wiki Activity Actions

Essays#getEssays(List<User>) reuses single AsyncHttpClient instance and closes it

Browse source
This commit is contained in:
moandji.ezana 2012-10-20 14:27:33 +02:00
parent effb94805f
commit ca07c8a35c
1 changed files with 30 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

50
src/main/java/com/moandjiezana/tent/essayist/Essays.java
View file

@ -1,10 +1,11 @@
package com.moandjiezana.tent.essayist; package com.moandjiezana.tent.essayist;
import com.google.common.base.Throwables; import com.google.common.base.Throwables;
import com.moandjiezana.tent.client.TentClient;
import com.moandjiezana.tent.client.TentClientAsync; import com.moandjiezana.tent.client.TentClientAsync;
import com.moandjiezana.tent.client.posts.Post; import com.moandjiezana.tent.client.posts.Post;
import com.moandjiezana.tent.client.posts.PostQuery; import com.moandjiezana.tent.client.posts.PostQuery;
import com.ning.http.client.AsyncHttpClient;
import com.ning.http.client.providers.jdk.JDKAsyncHttpProvider;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections; import java.util.Collections;
@ -14,33 +15,42 @@ import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.Future; import java.util.concurrent.Future;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
public class Essays { public class Essays {
public List<Post> getEssays(List<User> users, TentClient tentClient) { private static final Logger LOGGER = LoggerFactory.getLogger(Essays.class);
public List<Post> getEssays(List<User> users) {
CopyOnWriteArrayList<Future<List<Post>>> futurePosts = new CopyOnWriteArrayList<Future<List<Post>>>(); CopyOnWriteArrayList<Future<List<Post>>> futurePosts = new CopyOnWriteArrayList<Future<List<Post>>>();
for (User user : users) { AsyncHttpClient httpClient = new AsyncHttpClient(new JDKAsyncHttpProvider(TentClientAsync.getDefaultAsyncHttpClientConfigBuilder().build()));
futurePosts.add(new TentClientAsync(user.getProfile()).getPosts(new PostQuery().entity(user.getProfile().getCore().getEntity()).postTypes(Post.Types.essay("v0.1.0"))));
}
List<Post> posts = new ArrayList<Post>(futurePosts.size()); try {
for (Future<List<Post>> postFuture : futurePosts) { for (User user : users) {
try { futurePosts.add(new TentClientAsync(user.getProfile(), httpClient).getPosts(new PostQuery().entity(user.getProfile().getCore().getEntity()).postTypes(Post.Types.essay("v0.1.0"))));
posts.addAll(postFuture.get());
} catch (Exception e) {
LoggerFactory.getLogger(Essays.class).error("Could not load Post", Throwables.getRootCause(e));
} }
}
List<Post> posts = new ArrayList<Post>(futurePosts.size());
Collections.sort(posts, new Comparator<Post>() { for (Future<List<Post>> futurePost : futurePosts) {
@Override try {
public int compare(Post post1, Post post2) { posts.addAll(futurePost.get());
return new Date(post2.getPublishedAt()).compareTo(new Date(post1.getPublishedAt())); } catch (Exception e) {
LOGGER.error("Could not load Post", Throwables.getRootCause(e));
}
} }
});
Collections.sort(posts, new Comparator<Post>() {
return posts; @Override
public int compare(Post post1, Post post2) {
return new Date(post2.getPublishedAt()).compareTo(new Date(post1.getPublishedAt()));
}
});
return posts;
} finally {
httpClient.close();
}
} }
} }