Java8,非同期処理の勉強をしていてCompletionStageクラスの勉強をしています。
質問の結論としては、コンパイルエラーを解決したいです。
以下のサイトのサンプルプログラムを実際に動かしています。
https://www.kannon.link/fuku/index.php/2016/11/06/01-19/
package java8;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.math.BigDecimal;
import java.net.URL;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Stream;
public class Main {
public static void main(String[] args) {
// TODO 自動生成されたメソッド・スタブ
System.out.println(Thread.currentThread().getName() + ": main() started.");
//Googleの株価
CompletableFuture cf1 = CompletableFuture.supplyAsync(() -> downloadStockInfo("GOOG"))
.thenApply(Main::extractClosePrices)
.thenAccept(Main::printAveragePrice);
//Amazonの株価
CompletableFuture cf2 = CompletableFuture.supplyAsync(() -> downloadStockInfo("AMZN"))
.thenApply(Main::extractClosePrices)
.thenAccept(Main::printAveragePrice);
//Appleの株価
CompletableFuture cf3 = CompletableFuture.supplyAsync(() -> downloadStockInfo("AAPL"))
.thenApply(Main::extractClosePrices)
.thenAccept(Main::printAveragePrice);
System.out.println(Thread.currentThread().getName() + ": main() running.");
cf1.get();
cf2.get();
cf3.get();
System.out.println(Thread.currentThread().getName() + ": main() end.");
}
/**
* YahooファイナンスのURLから指定した銘柄の数年分の株価情報を取得する
* @param ticker 銘柄のID
* @return 株価情報テーブル
*/
private static Stream downloadStockInfo(final String ticker) {
try {
URL url = new URL("https://ichart.finance.yahoo.com/table.csv?s=" + ticker);
BufferedReader reader = new BufferedReader(new InputStreamReader(url.openStream()));
System.out.println(Thread.currentThread().getName() + ": downloadStockInfo() executed. ticker " + ticker);
return reader.lines();
} catch(Exception ex) {
throw new RuntimeException(ex);
}
}
/**
* 株価情報テーブルから終値を抽出する
* @param stockInfo 株価情報テーブル
* @return 株価情報テーブルから抽出した終値
*/
private static Stream extractClosePrices(Stream stockInfo) {
Stream closePricesStr = stockInfo.skip(1).map(x -> x.split(",")[4]);
Stream closePrices = closePricesStr.map(BigDecimal::new);
System.out.println(Thread.currentThread().getName() + ": getClosePrice() executed.");
return closePrices;
}
/**
* 終値の平均値を計算し出力する
* @param closePrices 終値の数年分のリスト
*/
private static void printAveragePrice(Stream closePrices){
Double average = closePrices.mapToDouble(BigDecimal::doubleValue).average().getAsDouble();
System.out.println(Thread.currentThread().getName() + ": printAveragePrice() executed. avg " + average + ".");
}
}
説明 リソース パス ロケーション 型
The type BigDecimal does not define BigDecimal(Object) that is applicable here Main.java /lucene/src/main/java8 行 57 Java 問題
The type BigDecimal does not define doubleValue(Object) that is applicable here Main.java /lucene/src/main/java8 行 67 Java 問題
メソッド split(String) は型 Object で未定義です Main.java /lucene/src/main/java8 行 56 Java 問題
型 Stream のメソッド map(Function) は引数 (BigDecimal::new) に適用できません Main.java /lucene/src/main/java8 行 57 Java 問題
型 Stream のメソッド mapToDouble(ToDoubleFunction) は引数 (BigDecimal::doubleValue) に適用できません Main.java /lucene/src/main/java8 行 67 Java 問題
なぜこのエラーが起きているか調べているのですが、まだ解決に至っていません。
エラーメッセージで検索をかけたり、BigDecimalやメソッド参照について調べました。
もしわかる方がいればお願いいたします。