使用LinkedBlockingQueue并刷新到mysql(Using a LinkedBlockingQueue and flush to mysql)

 
 
 问 ：为什么我无法使用.parallal（）？ 
 
 
 问 ：访问外部元素时我该怎么办？ 
 
 
 您可以在并行流中使用它，当操作不修改共享状态时没有问题，例如： 
 
stream.peek(System.out::println).allMatch(...);
 
 如果操作修改共享状态，则它负责提供所需的同步，例如： 
 
stream.peek(it->{synchronized(lock){ keys.set(idx, null); }}).allMatch(...);
 
 
 
 问 ：为什么我们不应该使用peek（）？ 
 
 
 您可以使用peek()方法，但如果无法控制流，则应避免使用peek() ，例如： 
 
boolean foo(){ stream.peek(...).allMatch(..); }

//a violate rule
Stream<?> foo(){
  /*you need avoiding using peek() here since you can't control the stream*/
}
 
 
 
 问 ：我应该如何将代码“转移”到java 8流？ 
 
 
 有一个详细的描述如何在其包汇总java.util.stream中操作流。 

 
 
Q: Why am I unable to use .parallal()?
 
 
Q: What should I do when accessing outside elements?
 
 
you can use it in a parallel stream, there is no problem when the action doesn't modify shared state there, for example:
 
stream.peek(System.out::println).allMatch(...);
 
If the action modifies shared state, it is responsible for providing the required synchronization, for example:
 
stream.peek(it->{synchronized(lock){ keys.set(idx, null); }}).allMatch(...);
 
 
 
Q: Why shouldn't we use peek()?
 
 
you can using the peek() method, but you should avoiding using peek() if you can't control the stream, for example:
 
boolean foo(){ stream.peek(...).allMatch(..); }

//a violate rule
Stream<?> foo(){
  /*you need avoiding using peek() here since you can't control the stream*/
}
 
 
 
Q: How should I "transfer" the code to java 8 streams?
 
 
there is a detailed description how to operates a stream in its package summary java.util.stream.