list.stream()
.forEach(x -> System.out.println(x.getDescription()));

Contient du porc
Contient anko
Contient anko
Contient anko
C'est un terme général pour Anmanbutaman etc.

<détails> <résumé> avec </ résumé>

list.stream()
.distinct()
.forEach(x -> System.out.println(x.getDescription()));

Contient du porc
Contient anko
C'est un terme général pour Anmanbutaman etc.

sorted Trier comme son nom l'indique. Dans cet exemple, les éléments nommés key (ABC) sont triés dans l'ordre.

sorted

list.stream()
.sorted((o1, o2) -> o1.getKey().compareTo(o2.getKey()))
.forEach(x -> System.out.println(x.getKey() + x.getValue() + x.getDescription()));

Résultat d'exécution

Un Anman Anko est inclus
B Butaman contient du porc
C Chukaman Anmanbutaman etc.

peek Cela ne manipule pas spécifiquement le contenu du flux, Cela ressemble à une méthode de débogage. peek = Un aperçu (traduit littéralement)

peek

list.stream()
.peek(x -> System.out.println(x))
.forEach(x -> System.out.println("Sortie avec forEach"));

Résultat d'exécution

key:B value:Description du butaman:Contient du porc
Sortie avec forEach
key:A value:Description d'Anman:Contient anko
Sortie avec forEach
key:C value:Description de Chukaman:C'est un terme général pour Anmanbutaman etc.
Sortie avec forEach

Je me demandais si forEach serait fait après que tous les aperçus aient été faits en premier, mais il semble que le traitement intermédiaire → le traitement de fin soit fait pour chaque élément.

limit Tronquez le nombre de flux au nombre spécifié.

limit

list.stream()
.limit(2)
.forEach(x -> System.out.println(x));

Résultat d'exécution

key:B value:Description du butaman:Contient du porc
key:A value:Description d'Anman:Contient anko

skip Contrairement à la limite, il saute le début de Stream.

skip

list.stream()
.skip(1)
.forEach(x -> System.out.println(x));

Résultat d'exécution

key:A value:Description d'Anman:Contient anko
key:C value:Description de Chukaman:C'est un terme général pour Anmanbutaman etc.

Opération de terminaison

forEach Je l'ai utilisé avec désinvolture à chaque fois jusqu'à présent. Traite tous les éléments de Stream. … Mais il semble que la commande ne soit pas garantie. Uniquement pour les flux parallèles?

forEachOrdered C'est la même chose que forEach, mais il semble que la commande soit garantie en utilisant ceci.

toArray Faites simplement du flux un tableau.

toArray

Object[] testBeans = list.stream().toArray();
System.out.println(testBeans[0].toString());
System.out.println(testBeans[1].toString());

Résultat d'exécution

key:B value:Description du butaman:Contient du porc
key:A value:Description d'Anman:Contient anko

reduce réduire = réduire, réduire (littéralement) Cela semble utile lors de l'agrégation du contenu de Stream. Dans cet exemple, l'élément nommé value est attaché. Un seul facultatif est renvoyé par Stream. En outre, il existe également une réduction qui peut définir la valeur initiale. Différence de signature.

reduce

Optional<TestBean> opt = list.stream()
.reduce((t, u) -> {
  t.setValue(t.getValue() + u.getValue());
  return t;
});
System.out.println(opt.orElse(new TestBean("x", "x", "x")));

Résultat d'exécution

key:B value:Description de Butaman Anman Chukaman:Contient du porc

collect Il semble être utilisé lorsque vous souhaitez le renvoyer en tant que collection au lieu d'un seul élément comme facultatif. Collection → Modifier en tant que flux → Sortie en tant que collection Je pense que je l'utilise assez souvent.

Si vous souhaitez implémenter sérieusement les différentes interfaces qui sont les arguments de collect par vous-même, vous devez écrire environ 5 méthodes abstraites, il est donc facile d'utiliser la méthode statique fournie dans la classe Collectors.

collect

List<TestBean> newlist = list.stream()
  .filter(x -> x.getKey().equals("C"))
  .collect(Collectors.toList());
System.out.println(newlist.get(0).toString());

Résultat d'exécution

key:C value:Description de Chukaman:C'est un terme général pour Anmanbutaman etc.

min Comme son nom l'indique, il renvoie le plus petit comme facultatif. Le minimum est le même que pour le tri, et le comparateur est implémenté et défini. Dans cet exemple, spécifiez l'élément appelé key.

min

Optional<TestBean> op = list.stream()
  .min((x, y) -> x.getKey().compareTo(y.getKey()));
System.out.println(op.orElse(new TestBean("x", "x", "x")).toString());

Résultat d'exécution

key:A value:Description d'Anman:Contient anko

max Le contraire de min!

max

Optional<TestBean> op = list.stream()
  .max((x, y) -> x.getKey().compareTo(y.getKey()));
System.out.println(op.orElse(new TestBean("x", "x", "x")).toString());

Résultat d'exécution

key:C value:Description de Chukaman:C'est un terme général pour Anmanbutaman etc.

count Comme son nom l'indique, il renvoie le nombre d'éléments Stream.

count

System.out.println(list.stream().count());

Résultat d'exécution

3

anyMatch Comme je l'ai lu, il renvoie vrai si l'une des conditions de Stream est remplie. Dans cet exemple, nous recherchons un élément avec la clé "A".

anyMatch

boolean matched = list.stream().anyMatch(x -> x.getKey().equals("A"));
if (matched) {
  System.out.println("Il y avait un homme!");
}

Résultat d'exécution

Il y avait un homme!

allMatch Tant que vous ne lirez pas ceci également, il renvoie true si tous les éléments du Stream remplissent les conditions spécifiées.

allMatch

boolean matched = list.stream().allMatch(x -> !x.getKey().equals("Z"));
if (matched) {
  System.out.println("Tout le monde n'est pas Z!");
}

Résultat d'exécution

Tout le monde n'est pas Z!

noneMatch Renvoie true s'il n'y a rien de tel dans le Stream.

noneMatch

boolean noMatched = list.stream().noneMatch(x -> x.getKey().equals("Z"));
if (noMatched) {
  System.out.println("Il n'y avait pas de guerrier Z");
}

Résultat d'exécution

Il n'y avait pas de guerrier Z

findFirst Comme son nom l'indique, il renvoie le premier!

findFirst

Optional<TestBean> op = list.stream().findFirst();
System.out.println(op.orElse(new TestBean("x", "x", "x")).toString());

Résultat d'exécution

key:B value:Description du butaman:Contient du porc

findAny Il passe par son nom et renvoie quelque chose. Je parle de quelque chose ... Je ne sais pas vraiment ce qui sera retourné. Vous ne pouvez pas spécifier d'argument. Quand je l'ai essayé avec un flux séquentiel, le premier élément a été renvoyé, mais il semble qu'il n'y ait aucune garantie. (2018/12/08 j'ai reçu un commentaire et l'ai corrigé)

findAny

Optional<TestBean> op = list.stream().findAny();
System.out.println(op.orElse(new TestBean("x", "x", "x")).toString());

Résultat d'exécution

key:B value:Description du butaman:Contient du porc

Expériences autres que la méthode

Vérifiez que la source d'origine n'a pas changé même si vous utilisez Stream

J'ai écrasé l'élément de valeur du bean dans le flux avec une chaîne fixe. La source (List) n'a certainement pas changé.

<détails>

System.out.println("【Changer avant】");
for (TestBean bean : list) {
  System.out.println(bean);
}

list.stream().map(x -> {
  x.setValue("Je l'ai changé!");
  return x;
});

System.out.println("[Après le changement]");
for (TestBean bean : list) {
  System.out.println(bean);
}

【Changer avant】
key:B value:Description du butaman:Contient du porc
key:A value:Description d'Anman:Contient anko
key:C value:Description de Chukaman:C'est un terme général pour Anmanbutaman etc.
[Après le changement]
key:B value:Description du butaman:Contient du porc
key:A value:Description d'Anman:Contient anko
key:C value:Description de Chukaman:C'est un terme général pour Anmanbutaman etc.

    final int loopsize = 150000000;
    final int randomrange = 100;
    final int findnum = 99;

    // create many data
    System.out.println("Pendant la génération des données de test...");
    List<Integer> list = IntStream.range(0, loopsize)
        .mapToObj(x -> new Random().nextInt(randomrange))
        .collect(Collectors.toList());

    // byList
    LocalDateTime starttime = start("--- byList ---");
    List<Integer> newlist = new ArrayList<>();
    for (Integer i : list) {
      if (i.intValue() == findnum) {
        newlist.add(i);
      }
    }
    end(starttime, findnum, newlist);

    // byStream
    starttime = start("--- byStream ---");
    List<Integer> streamlist = list.stream()
        .filter(x -> x.intValue() == findnum).collect(Collectors.toList());
    end(starttime, findnum, streamlist);

    // byParalellStream
    starttime = start("--- byParalellStream ---");
    List<Integer> paralellStreamlist = list.parallelStream()
        .filter(x -> x.intValue() == findnum).collect(Collectors.toList());
    end(starttime, findnum, paralellStreamlist);
  }

  private static LocalDateTime start(String msg) {
    System.out.println("");
    System.out.println(msg);
    LocalDateTime ldt = LocalDateTime.now();
    System.out.println("start: " + ldt);
    return ldt;
  }

  private static void end(LocalDateTime starttime, int findnum,
      List<Integer> newlist) {
    LocalDateTime elapsed = LocalDateTime.now();
    System.out.println("end  : " + elapsed);
    elapsed = elapsed.minusHours(starttime.getHour());
    elapsed = elapsed.minusMinutes(starttime.getMinute());
    elapsed = elapsed.minusSeconds(starttime.getSecond());
    elapsed = elapsed.minusNanos(starttime.getNano());
    System.out
        .println("elapsed: " + elapsed.format(DateTimeFormatter.ISO_TIME));
    System.out.println(findnum + "Est" + newlist.size() + "Il y en avait un!");
  }

Pendant la génération des données de test...

--- byList ---
start: 2018-12-08T15:35:51.584
end  : 2018-12-08T15:35:52.039
elapsed: 00:00:00.455
Il y en avait 1500072 99!

--- byStream ---
start: 2018-12-08T15:35:52.052
end  : 2018-12-08T15:35:52.450
elapsed: 00:00:00.398
Il y en avait 1500072 99!

--- byParalellStream ---
start: 2018-12-08T15:35:52.450
end  : 2018-12-08T15:35:52.672
elapsed: 00:00:00.222
Il y en avait 1500072 99!

    List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

    System.out.println("--- byList ---");
    for (int i : list) {
      System.out.println(i);
    }

    System.out.println("--- byStream ---");
    list.stream().forEach(i -> System.out.println(i));

    System.out.println("--- byParallelStream ---");
    list.parallelStream().forEach(i -> System.out.println(i));

    System.out
        .println("findany by stream:" + list.stream().findAny().orElse(null));

    System.out.println("findany by parallelStream:"
        + list.parallelStream().findAny().orElse(null));

--- byList ---
1
2
3
4
5
6
7
8
9
10
--- byStream ---
1
2
3
4
5
6
7
8
9
10
--- byParallelStream ---
7
9
6
3
5
2
10
1
4
8
findany by stream:1
findany by parallelStream:7