Найти ответы in Java

[tessob]

Умный да?
Ты хоть свои коды через Eclipse пропускаешь?

Не, не проверял, не было возможности. Просто дописал сортировку по памяти из переговорки во время митинга. Чтоб сортировка заработала корректно нужно поменять parallelStream() на stream().
В параллельных стримах сортировка имеет смысл только (вроде) перед вызовом коллектора. Я думал, что это очевидно, поэтому и не стал весь класс еще раз выкладывать.

Для работы нужны такие зависимости:

Code: Select all

    <dependencies>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactId>
            <version>2.10.1</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.10.1</version>
        </dependency>
    </dependencies>

Полностью работающий класс с сортировкой:

Code: Select all

import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;

import java.io.File;
import java.io.IOException;
import java.util.Comparator;
import java.util.List;
import java.util.Map;
import java.util.stream.Stream;

public class Application {

    public static void main(String[] args) {
        getStreamFromFile("coordinates.json")
                .sorted(Comparator.comparingDouble(a -> a.distanceTo(6, 31)))
                .map(r -> "pivot: " + r.id + ", distance: " + r.distanceTo(6,31))
                .forEach(System.out::println);
    }

    private static Stream<Record> getStreamFromFile(String filename) {
        try {
            return new ObjectMapper()
                    .readValue(new File(filename), new TypeReference<List<Map<String, String>>>() {
                    })
                    .stream()
                    .map(m -> new Record(m.get("id"), m.get("value")));
        } catch (IOException e) {
            e.printStackTrace();
            return Stream.empty();
        }
    }

}

Вывод в stdout будет таким:

Code: Select all

pivot: a, distance: 18.681541692269406
pivot: d, distance: 20.518284528683193
pivot: z, distance: 26.076809620810597
pivot: t, distance: 29.732137494637012
pivot: o, distance: 30.265491900843113
...

Что ты в этом выражении «r -> r.distanceTo(6, 31)» с чем сравниваешь?
Чтобы сортировать запись в классе по производимому результату, нужно какой-то носитель создать! Если мы стрим трансформируем в результат, то потеряем «id», так что опять нужно создавать map для «id» и «distanceTo», и вот тогда можно сортировать.

Там же функтор можно поставить. Вот я и поставил.

З.Ы. Если совсем ничего не компилируется и не запускается, то я могу просто репозиторий выложить куда-нибудь.

[KinDzaDza]

А попроще на Java разве нельзя было написать? Кложуры и функторы это конечно круто но нахрена нам это все тут?

Code: Select all

public static class Point {
  public String id;
  public int x;
  public int y;
  public int distance;
  public Point(String id, int x, int y) { this.id = id; this.x = x; this.y = y; this.distance = 0; }
}

List<Point> points = getPoints("coordinates.json"); // see below for implementation details, they are actually irrelevant to the task we are solving here. 
Point origin = new Point("Origin", 12, 34);
// calculate distance
for(Point point : points) {
  int x = origin.x - point.x;
  int y = origin.y - point.y;
  point.distance = x*x + y*y; // add Math.sqrt() if you want
}
// sort by distance
Collections.sort(points, new Comparator<Point>() { int compare(Point a, Point b) { return a.distance - b.distance; } } );
// print them sorted
for(Point point : points) {
  System.out.println(point.id);
}

List<Point> getPoints(String fileName) {
  List<Point> points = new ArrayList<>();
  // ...
  // use your favorite JSON library here like GSON, Jackson, SimpleJson etc,
  // or if you are really cool parse file manually
  // ...
  // 
  // iterate through all records in this file and 
  // for each record from the file add new Point(id, x, y) object to the points list.
  //
  return points;
}

[brrdrr]

Стрим в Java вещь новая и ещё толком непонятно, когда она реально необходима. Вроде разгружает процесс написания кода, но жутко напрягает железо.
А так чем проще пишешь, тем быстрее ездит, и проще находить проблемы.

[brrdrr]

А попроще на Java разве нельзя было написать? Кложуры и функторы это конечно круто но нахрена нам это все тут?

Задачка простая как тест на владение загрузкой JSON.
Я старался создавать минимум объектов.
Но раз вы решили создавать 26 объектов класса Point, то зачем его делать статическим? Да и метод по расчёту дистанции тогда нужно запихать в этот класс.
Я бы так переписал ваш класс. (заранее извиняюсь, что посмел дотронуться до шедевра)

Code: Select all

public class Point {
		private final String id;
		private final int x;
		private final int y;
		private double distance;

		public Point(String id, int x, int y) {
			this.id = id;
			this.x = x;
			this.y = y;
			this.distance = 0;
		}

		/**
		 * @return the id
		 */
		public String getId() {
			return id;
		}

		/**
		 * @return the x
		 */
		public int getX() {
			return x;
		}

		/**
		 * @return the y
		 */
		public int getY() {
			return y;
		}

		/**
		 * @return the distance
		 */
		public double getDistance() {
			return distance;
		}

		/**
		 * @param distance calculation from origin point x and y to paticualr point
		 */
		public double calDistance(int x, int y) {
			return this.distance = StrictMath.hypot(this.x - x, this.y - y);
		}

	}

[tessob]

А попроще на Java разве нельзя было написать? Кложуры и функторы это конечно круто но нахрена нам это все тут?

Если Вы допишете свой код до рабочего состояния, то он получится значительно длиннее моего. Просто, если бы JSON был разумнее организован, без двух значений в поле value, то я бы написал это и без дополнительного класса. Вы же эту проблему совсем опустили. Опять же, если мы прогоним потом наш код каким-либо линтером, вроде того, что в Idea, то он развернет все ваши однострочные конструкторы и компараторы. Так-то я тоже могу записать все в одну строку, которая будет и не читаемая, и не поддерживаемая.

Я бы так переписал ваш класс...

Вот это вот - очень порочная практика:

Code: Select all

public class Point {

  private double distance;

  public double getDistance() 

  public double calDistance(int x, int y)
		
}

Вы когда вызываете getDistance у подобных классов, всегда уверены к какому именно состоянию Вы обращаетесь и дистанцию до чего получите? Например, если придется обрабатывать подобные классы многопоточно, как элемент разделяемой памяти. Если Вы так сильно хотите сэкономить на двойном вычислении дистанции, для сортировки и для печати, то почему не создать отдельный иммутабельный класс для этого, где вы будете хранить то состояние, которое вам нужно для печати. Это не Вам упрек, а скорее напутствие автору топика и тем, кто его просматривает, чтоб почерпнуть знания.

[brrdrr]

Вот это вот - очень порочная практика:

Code: Select all

public class Point {

  private double distance;

  public double getDistance() 

  public double calDistance(int x, int y)
		
}

Вы когда вызываете getDistance у подобных классов, всегда уверены к какому именно состоянию Вы обращаетесь и дистанцию до чего получите? Например, если придется обрабатывать подобные классы многопоточно, как элемент разделяемой памяти. Если Вы так сильно хотите сэкономить на двойном вычислении дистанции, для сортировки и для печати, то почему не создать отдельный иммутабельный класс для этого, где вы будете хранить то состояние, которое вам нужно для печати. Это не Вам упрек, а скорее напутствие автору топика и тем, кто его просматривает, чтоб почерпнуть знания.

С этим я согласен, для параллельной работы этот класс не годится. Стало быть ещё един класс с 26 новыми объектами.
Невольно возникает вопрос: а зачем тогда стрим с параллельной работой, если старый добрый метод работает быстрее?

[tessob]

Невольно возникает вопрос: а зачем тогда стрим с параллельной работой, если старый добрый метод работает быстрее?

Параллельные стирмы удобны во всяких middleware workers, например когда вам нужно разгребать очередь сообщений, вроде Kafka или SQS, и для каждого сообщения нужно ходить в разные базы, что-нибудь валидировать, общаться с другими сервисами и потом все это заталкивать в какой-нибудь NoSQL. Параллельные стримы в подобных случаях будут выполняться полностью асинхронно для каждого из элементов, используя общий форк-джойн пул. В результате, пока одни "таски" будут спать, ожидая ответа другого сервера, остальные будут что-то делать. С обычным стримом у вас все "таски" будут ждать пока не выполнятся все предыдущие.

[brrdrr]

Невольно возникает вопрос: а зачем тогда стрим с параллельной работой, если старый добрый метод работает быстрее?

Параллельные стирмы удобны во всяких middleware workers, например когда вам нужно разгребать очередь сообщений, вроде Kafka или SQS, и для каждого сообщения нужно ходить в разные базы, что-нибудь валидировать, общаться с другими сервисами и потом все это заталкивать в какой-нибудь NoSQL. Параллельные стримы в подобных случаях будут выполняться полностью асинхронно для каждого из элементов, используя общий форк-джойн пул. В результате, пока одни "таски" будут спать, ожидая ответа другого сервера, остальные будут что-то делать. С обычным стримом у вас все "таски" будут ждать пока не выполнятся все предыдущие.

Какую-нибудь хорошую книжку по стримам Java 8 можете посоветовать?

[KinDzaDza]

А попроще на Java разве нельзя было написать? Кложуры и функторы это конечно круто но нахрена нам это все тут?

Задачка простая как тест на владение загрузкой JSON.
Я старался создавать минимум объектов.
Но раз вы решили создавать 26 объектов класса Point, то зачем его делать статическим? Да и метод по расчёту дистанции тогда нужно запихать в этот класс.
Я бы так переписал ваш класс. (заранее извиняюсь, что посмел дотронуться до шедевра)

Code: Select all

public class Point {
		private final String id;
		private final int x;
		private final int y;
		private double distance;

		public Point(String id, int x, int y) {
			this.id = id;
			this.x = x;
			this.y = y;
			this.distance = 0;
		}

		/**
		 * @return the id
		 */
		public String getId() {
			return id;
		}

		/**
		 * @return the x
		 */
		public int getX() {
			return x;
		}

		/**
		 * @return the y
		 */
		public int getY() {
			return y;
		}

		/**
		 * @return the distance
		 */
		public double getDistance() {
			return distance;
		}

		/**
		 * @param distance calculation from origin point x and y to paticualr point
		 */
		public double calDistance(int x, int y) {
			return this.distance = StrictMath.hypot(this.x - x, this.y - y);
		}

	}

Да что Вы, какой тут шедевр, ни гетеров, ни сеттеров, ни новомодных функторов. Но позвольте с Вами тут в паре-тройке моментов немножко не согласиться.
Класс Point пофиг как объявить, если вложенный, то лучше статическим, чтобы потом можно было использовать ещё где.
Класс Point написан именно так потому что эти геттеры и сеттеры тут ну нахрен никому не уперлись в принципе, это простой и тупой дата холдер.
Создавать 26 объектов класса Point это не комильфо, а плодить на лету два хэшмапа каждый с 26 парами объектов и хрен знает чем ещё для своего внутреннего использования - это типа гораздо лучше.

[Komissar]

Как страшно жить! (c)

[tessob]

Какую-нибудь хорошую книжку по стримам Java 8 можете посоветовать?

Я обычно не читаю книжки по новым возможностям языков, так как к моменту их публикации возможности становятся уже не новыми. Мой основной источник информации -- это записи с конференций и блоги. Могу посоветовать посмотреть на ютубе видео Сергей Куксенко по "Stream API". Тагир Валеев тоже неплохо рассказывал.

[iDesperado]

Какую-нибудь хорошую книжку по стримам Java 8 можете посоветовать?

Modern Java in Action: Lambdas, streams, functional and reactive programming

[8K]

Как страшно жить! (c)

You don't say! Duff's device:

Code: Select all

send(to, from, count)
register short *to, *from;
register count;
{
    register n = (count + 7) / 8;
    switch (count % 8) {
    case 0: do { *to = *from++;
    case 7:      *to = *from++;
    case 6:      *to = *from++;
    case 5:      *to = *from++;
    case 4:      *to = *from++;
    case 3:      *to = *from++;
    case 2:      *to = *from++;
    case 1:      *to = *from++;
            } while (--n > 0);
    }
}

[8K]

Some things are just hilarious.
Beyond Floating Point: Next-Generation Computer Arithmetic
aP0Y1uAA-2Y by John L. Gustafson.

[brrdrr]

Вот тоже задачка на Java.
Имеется array и нужно найти минимальную разницу между его членами.
Так решение выглядит без стрима.

Code: Select all

public class Solution {
    static int minimumAbsoluteDifference(int[] arr) {
        int min = Integer.MAX_VALUE;
        Arrays.sort(arr);
        for( int i = 0; i < arr.length - 1; i++){
                min = Math.min(Math.abs(arr[i] - arr[i + 1]), min);                     
            }
    return min;
    }

Я пытался полностью реализовать эту задачу в стриме, но не получилось.
Можно ли сортировку воткнуть в стрим?

Code: Select all

public class Solution {
    static int minimumAbsoluteDifference(int[] arr) {
       Arrays.sort(arr);
        return IntStream.range(0, arr.length - 1)
                .mapToObj(i -> Math.abs(arr[i + 1] - arr[i]))
                .min(Integer::compare).get(); 
    }