在流的foreach的Java 8

Question

递增计数器，我想增加一个counter这是一个AtomicInteger，我通过循环使用foreach

public class ConstructorTest { 

public static void main(String[] args) { 
    AtomicInteger counter = new AtomicInteger(0); 
    List<Foo> fooList = Collections.synchronizedList(new ArrayList<Foo>()); 
    List<String> userList = Collections.synchronizedList(new ArrayList<String>()); 
    userList.add("username1_id1"); 
    userList.add("username2_id2"); 

    userList.stream().map(user -> new Foo(getName(user), getId(user))).forEach(fooList::add); 
    //how do I increment the counter in the above loop 

    fooList.forEach(user -> System.out.println(user.getName() + " " + user.getId())); 
} 

private static String getName(String user) { 
    return user.split("_")[0]; 
} 

private static String getId(String user) { 
    return user.split("_")[1]; 
} 
} 

Answer 1

取决于您想增加的位置。

要么

userList.stream() 
     .map(user -> { 
       counter.getAndIncrement(); 
       return new Foo(getName(user), getId(user)); 
      }) 
     .forEach(fooList::add); 

或

userList.stream() 
     .map(user -> new Foo(getName(user), getId(user))) 
     .forEach(foo -> { 
      fooList.add(foo); 
      counter.getAndIncrement(); 
     }); 

Answer 2

你可以把它改成一个匿名类：

 userList.stream().map(new Function<String, Object>() { 
      @Override 
      public Object apply(String user) { 
       counter.addAndGet(1); 
       return new Foo(getName(user), getId(user)); 
      } 
     }).forEach(fooList::add); 

记得制作counterfinal。