기본 콘텐츠로 건너뛰기

자바 스트림 재사용

은 불가하다.

조금더 구체적으로 말하면
스트림 함수중 내부적으로 reduce()를 호출하는 경우에 불가능하다.

이렇게 설계한 배경은 조금더 찾아봐야 하겠지만
불가능한 이유는 다음과 같다.

IntStream의 sum()의 구현체다
sum() 함수는 다음 순서대로 진행된다. 
sum() -> reduce() -> AbstractPiplie.evaluate()

abstract class IntPipeline<E_IN>
        extends AbstractPipeline<E_IN, Integer, IntStream>
        implements IntStream {
....

  @Override  public final int sum() {
    return reduce(0, Integer::sum);  }

...

  @Override  public final int reduce(int identity, IntBinaryOperator op) {
    return evaluate(ReduceOps.makeInt(identity, op));  }


}


그리고 evaluate함수는 상속받은 AbstractPipeLine에 구현되어있다.
처음 호출되었을때 해당 파이프라인의 linkedOrConsumed 를 true로 변환하고 이후에 호출되었을시
예외처리를 하게끔 되어있다.   
abstract class AbstractPipeline<E_IN, E_OUT, S extends BaseStream<E_OUT, S>>
        extends PipelineHelper<E_OUT> implements BaseStream<E_OUT, S> {
    private static final String MSG_STREAM_LINKED = "stream has already been operated upon or closed";    private static final String MSG_CONSUMED = "source already consumed or closed";

...
/** * Evaluate the pipeline with a terminal operation to produce a result. * * @param <R> the type of result * @param terminalOp the terminal operation to be applied to the pipeline. * @return the result */final <R> R evaluate(TerminalOp<E_OUT, R> terminalOp) {
    assert getOutputShape() == terminalOp.inputShape();    if (linkedOrConsumed)
        throw new IllegalStateException(MSG_STREAM_LINKED);    linkedOrConsumed = true;
    return isParallel()
           ? terminalOp.evaluateParallel(this, sourceSpliterator(terminalOp.getOpFlags()))
           : terminalOp.evaluateSequential(this, sourceSpliterator(terminalOp.getOpFlags()));}.


댓글

이 블로그의 인기 게시물

메일서버가 스팸으로 취급받을때

설치한 메일서버를 통해 발송되는 메일이 스팸으로 들어가는 경우가 더러 있다. 이게 한번 들어가기는 쉬운데, 빠져나오기는 드럽게 힘든것 같다... 본인의 경우에는 우선 국내서비스에는 별 무리 없이 들어간다. (naver,daum 등) 그런데 해외메일 그중 Gmail, Hotmail 에는 에누리없이 스팸으로 간주되고 있었다. Gmail같은 경우에는 그래도 스팸함으로 발송은 제대로 되는반면에 Hotmail같은경우에는 아예 수신자체가 안되는 경우도 더러있다.. ㅡ,.ㅡ; 제일 좋은 방법은 Gmail,Hotmail에 전화걸어서 우리 메일서버 IP white Ip로 등록해달라!!! 하면 좋지만, 얘네들은 걸어봤자 자동응답기고, 문의채널은 구글 그룹스 게시판이 전부다.. 본론으로 들어가서. 해외 메일이 차단될 경우 내 매일서버ip가 스팸ip로 등록되 버린 경우일 수 있다. (본인처럼. ㅎ) 이것부터 조회 해보고 싶으면 RBL(real-time blocking List) 체크를 해야 하는데, RBL체크 해주는 사이트는 꽤 많이 있고, 그중 좀 깔끔해 보이는곳 하나 소개. http://www.anti-abuse.org/ 메일서버ip 입력하고 조회해보면 쭈루룩 리스트가 나온다. 그 중 빨간불이 들어온 부분이 메일 서버가 스팸서버가 된 각종 이유들이다.ㅋ 본인의 경우 CBL 때문에 걸렸는데, 내용은 아래와 같다. This IP address is HELO'ing as  "localhost.localdomain"  which violates the relevant standards (specifically: RFC5321). 메일서버 도메인에 별다른 작업을 안해놓아서 "localhost.localdomain" 으로 설정되어있었다. 만약 CBL만 바로 테스트 해보고 싶으면 http://cbl.abusea...

[spring] 인터셉터 와 필터

스프링에서 전후처리기(?)를 담당하는 인터셉터 와   필터 라는게 있다.  둘다 알고 계신 훌륭한 개발자 분들도 많으시겠지만 ㅋ  본인처럼 인터셉터만 알고 있는 경우에는  가볍게라도 필터에 대해서 알아두시라고 몇자 적어 본다. ㅎ  사실  기능만 보면  인터셉터와 필터는  무척 비슷해 보인다.  게다가 filter로 해야 되는 일들은  사실   interceptor로 해결할 수 있는 듯 하다.  (적어도 본인이 하고 있는 프로젝트에서는.. ㅋ) 구글 창에다가  'difference interceptor and filter' 의 검색결과가 여러페이지 나오는 걸 보면 많은 사람들이 궁금해 하는게  다 이러한 이유인것 같다.  본론으로 들어가서  우선 인터셉터 설정파일을 보면  < mvc:interceptors > < mvc:interceptor > < mvc:mapping path = "/api1/*" /> < mvc:mapping path = "/api2/*" /> < mvc:mapping path = "/api3/*" /> < bean class = "com.changpd.test.interceptor.인터셉터클래스" /> </ mvc:interceptor > </ mvc:interceptors > 보통 이런식으로 선언 되어있을듯 하다.  해석은  api1,2,3 호출되기전에 인터셉터클래스를 먼저 호출하겠다.  뭐 이런...

jwt 토큰생성

 jwt는  header, claims, signature 영역으로 이루어진다.  그러나 jwtbuilder의 멤버변수는 다음과 같다.  header/claims/signature의 3개의 변수는 아니다.  public class DefaultJwtBuilder implements JwtBuilder { private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper() ; private Header header ; private Claims claims ; private String payload ; private SignatureAlgorithm algorithm ; private Key key ; private byte [] keyBytes ; private CompressionCodec compressionCodec ; jwtbuilder 사용예제를 보면 다음과 같다.  String jws = Jwts.builder() .setIssuer( "Stormpath" ) .setSubject( "msilverman" ) .claim( "name" , "Micah Silverman" ) .claim( "scope" , "admins" ) // Fri Jun 24 2016 15:33:42 GMT-0400 (EDT) .setIssuedAt(Date.from(Instant.ofEpochSecond( 1466796822L ))) // Sat Jun 24 2116 15:33:42 GMT-0400 (EDT) .setExpiration(Date.from(Instant.ofEpochSecond( 4622470422L ))) .signWith( SignatureAlgor...