Peek phần tử tiếp theo trong luồng

Question

Có cách nào để xem nhanh phần tử tiếp theo trong luồng không? Ý tưởng tăng từ một dòng của một danh sách các đối tượng, nơi mà hai đối tượng sau đây cần được so sánh (để làm mịn một số khác biệt, nhưng điều đó không quan trọng ở đây). Là một for loop cũ này sẽ như thế nào:

List<Car> autobahn = getCars(); 
for (int i = 0; i < autobahn.size()-1; i++) { 
    if(autobahn.get(i).speed>autobahn.get(i+1).speed) 
     autobahn.get(i).honk(); 
} 

Cách tốt nhất cho đến nay như dòng sẽ là:

autobahn.stream() 
      .limit(autobahn.size()-1) 
      .filter(car -> car.speed < autobahn.get(autobahn.indexOf(car)+1).speed) 
      .forEach(car -> car.honk()); 

Các chính-vấn đề với giải pháp này là phương pháp indexOf, vì có thể có hai lần cùng một chiếc xe trên autobahn. Một giải pháp tốt hơn sẽ có một số cách để nhìn trộm tiếp theo (hoặc một trước đó) phần tử (với một lớp giúp đỡ, điều này có thể thậm chí có thể, nhưng trông khủng khiếp)

BoxedCar boxedCar = new BoxedCar(autobahn.get(0)); 
autobahn.stream() 
      .skip(1) 
      .filter(car -> boxedCar.setContent(car)) 
      .forEach(car -> car.winTheRace()); 

với helperclass

class BoxedCar { 

    Car content; 

    BoxedCar(Car content) { 
     this.content = content; 
    } 
    boolean setContent(Car content) { 
     double speed = this.content.speed; 
     this.content = content; 
     return content.speed > speed; 
    } 
} 

hoặc để chuyển hướng Stream<Car> thành một loại Stream<(Car,Car)> với luồng thứ hai bằng cách nào đó được tạo ra bởi kênh thứ nhất (điều này nghe có vẻ khủng khiếp và ở đây tôi không có ý tưởng, cách này sẽ trông như thế nào).

Có cách nào tốt đẹp để làm điều này với luồng hoặc chúng tôi bị kẹt vào vòng lặp for không?

Answer 1

Gắn bó với vòng lặp for sẽ không phải là một ý tưởng tồi. API luồng không được thiết kế cho loại yêu cầu này. Bạn có thể tham khảo that answer để có thêm thông tin chi tiết.

Tuy nhiên, cách đơn giản để thực hiện việc này bằng API luồng sẽ là sử dụng Luồng trên các chỉ mục trong danh sách của bạn, giả sử bạn có quyền truy cập ngẫu nhiên.

IntStream.range(0, autobahn.size() - 1) 
     .filter(i -> autobahn.get(i).speed > autobahn.get(i+1).speed) 
     .forEach(i -> autobahn.get(i).honk()); 

Lưu ý rằng điều này rất giống với for vòng lặp.

Answer 2

gì về việc sử dụng IntStream thay vì một vòng lặp:

IntStream.range(0, autobahn.size() - 1) 
     .filter(i -> autobahn.get(i).speed < autobahn.get(i + 1).speed) 
     .forEach(i -> autobahn.get(i).honk()); 

Answer 3

Sử dụng miễn phí StreamEx thư viện của tôi:

StreamEx.of(autobahn) 
     .pairMap((car, nextCar) -> car.speed < nextCar.speed ? car : null) 
     .nonNull() 
     .forEach(Car::honk); 

Đây phi tiêu chuẩn pairMap hoạt động được sử dụng mà có thể lập bản đồ các cặp liền kề của các yếu tố thành phần tử đơn lẻ. Điều này làm việc cho bất kỳ nguồn luồng nào (không chỉ danh sách được lập chỉ mục truy cập ngẫu nhiên) và có thể được song song khá tốt.