streamやanalyzerどれをどのタイミングでclose,resetすればいいかを理解したい

Question

前提・実現したいこと

読み込みや書き込み、その際のstreamやanalyzerの

• どれをどのタイミングでclose,resetすればいいのか？
• どういう状況判断でclose,resetするのか
• そもそもなぜclose,resetしなければいけないのか

を理解したいです。

なので、それを解説してくれる方、またはこういう勉強法をすればいいよ！といったことを教えていただきたいです。

該当のソースコード

このコード内でclose,resetしていますが、なぜ、どういった判断で、どれをclose,resetすればいいのか知りたいです。

import java.io.IOException;
import java.util.Arrays;
import java.util.List;

import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.TokenStream;
import org.apache.lucene.analysis.ja.JapaneseAnalyzer;
import org.apache.lucene.analysis.ja.tokenattributes.ReadingAttribute;
import org.apache.lucene.analysis.ja.util.ToStringUtil;
import org.apache.lucene.analysis.tokenattributes.CharTermAttribute;
import org.apache.lucene.util.Version;

/**
 * ファイル内の文に形態素解析を適用します。
 */
public class Romanize {

    public static void main(String[] args) {
        Analyzer analyzer = new JapaneseAnalyzer(Version.LUCENE_47);
        try {
            List<String> texts = Arrays
                    .asList("すもももももももものうち。", "メガネは顔の一部です。",
                            "日本経済新聞でモバゲーの記事を読んだ。",
                            "Java, Scala, Groovy, Clojure",
                            "ＬＵＣＥＮＥ、ＳＯＬＲ、Lucene, Solr",
                            "ｱｲｳｴｵカキクケコさしすせそABCＸＹＺ123４５６",
                            "Lucene is a full-featured text search engine library written in Java.");
            for (String text : texts) {
                TokenStream tokenStream = analyzer.tokenStream("", text);
                try {
                    romanize(tokenStream);
                } catch (IOException e) {
                    e.printStackTrace();
                } finally {
                    tokenStream.close();  //←該当箇所
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            analyzer.close(); //←該当箇所
        }
    }

    private static void romanize(TokenStream tokenStream) throws IOException {
        CharTermAttribute charTermAttr = tokenStream
                .addAttribute(CharTermAttribute.class);
        ReadingAttribute readingAttr = tokenStream
                .addAttribute(ReadingAttribute.class);
        tokenStream.reset(); //←該当箇所
        while (tokenStream.incrementToken()) {
            String token = charTermAttr.toString();
            String reading = readingAttr.getReading();
            String readingRoma = null;
            if (reading != null) {
                readingRoma = ToStringUtil.getRomanization(reading);
            } else if (isHalfWidthAlphanumeric(token)) {
                readingRoma = token;
            } else {
                readingRoma = ToStringUtil.getRomanization(token);
            }
            System.out.println("token:" + token + " ,reading:" + reading
                    + " ,readingRoma:" + readingRoma);
        }
    }

    private static boolean isHalfWidthAlphanumeric(String text) {
        if (text == null || text.length() == 0
                || text.length() != text.getBytes().length) {
            return false;
        }
        return true;
    }

}

試したこと

ネットで「lucene 入門」「close stream Java」などのキーワードで調べています。

補足情報（FW/ツールのバージョンなど）

環境：Ecllipse4.8.0
言語：Java1.7

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>

	<groupId>net.comici.jp</groupId>
	<artifactId>analyzer-sample</artifactId>
	<version>1.0-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>analyzer-sample</name>
	<url>https://comici.jp</url>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
	</properties>

	<build>
		<plugins>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<configuration>
					<source>1.7</source>
					<target>1.7</target>
				</configuration>
			</plugin>
			<plugin>
				<groupId>org.codehaus.mojo</groupId>
				<artifactId>exec-maven-plugin</artifactId>
				<version>1.3</version>
				<executions>
					<execution>
						<goals>
							<goal>java</goal>
						</goals>
					</execution>
				</executions>
				<configuration>
					<mainClass>net.comici.test.AnalyzerSample</mainClass>
				</configuration>
			</plugin>
		</plugins>
	</build>

	<dependencies>
		<dependency>
			<groupId>org.apache.lucene</groupId>
			<artifactId>lucene-analyzers-kuromoji</artifactId>
			<version>4.8.1</version>
		</dependency>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>3.8.1</version>
			<scope>test</scope>
		</dependency>
	</dependencies>
</project>

Answer 1

なぜ、どういった判断で、どれをclose,resetすればいいのか

オブジェクトが何か資源を確保・使用していれば, それを解放しなければ, 資源が枯渇して全体の動作に支障をきたす恐れがあります.
ですので, 使用が済み次第極力速やかに開放する必要があります.
大抵は close メソッドがあれば close する必要があると判断できるでしょう.
各クラスのドキュメントを読むのが確実かと思います.

Comments

[k499778]

回答ありがとうございます。
コレはstreamだからでしょうか？
全てのオブジェクトでcloseしてる記述があるわけではないので。

[jimbe]

「stream だから」という判断基準は回答に入れていません.
クラス名は作者が自由に付けられますから, 「クラス名に Stream という文字が付いていれば必ず close する必要があり, 付いていなければ close する必要が無い」とは言えません. ( Analyzer には「 Stream 」は付いていません. )
ですので, 「各オブジェクトのドキュメントを読むのが確実」と申し上げています.

[jimbe]

すいません, 「各オブジェクト」では無く「各クラス」に修正しました.

[k499778]

かしこまりました