1 package us.codecraft.webmagic.pipeline; 2 3 import us.codecraft.webmagic.Task; 4 5 import java.util.ArrayList; 6 import java.util.List; 7 8 /** 9 * @author code4crafter@gmail.com 10 */ 11 public class CollectorPageModelPipeline<T> implements PageModelPipeline<T> { 12 13 private List<T> collected = new ArrayList<T>(); 14 15 @Override 16 public synchronized void process(T t, Task task) { 17 collected.add(t); 18 } 19 20 public List<T> getCollected() { 21 return collected; 22 } 23 }