在流数据处理过程中，排序是高频操作之一，默认的排序规则通常只能按照元素的自然顺序处理，无法适配业务层面的特殊排序需求，同时频繁的元素比较也容易造成性能损耗，通过合理使用sorted操作可以解决这两个问题。
sorted操作的基础用法
sorted是多数编程语言流处理库中提供的排序方法，支持对流中的元素进行整体排序，基础用法只需要指定排序规则即可。以Java的Stream API为例，对一个整数流进行升序排序的基础代码如下：
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class SortedBasicDemo {
public static void main(String[] args) {
List<Integer> sortedList = Stream.of(5, 3, 8, 1, 2)
// 调用sorted方法，默认升序排序
.sorted()
.collect(Collectors.toList());
System.out.println(sortedList); // 输出 [1, 2, 3, 5, 8]
}
}
流数据定制化排序的实现
当默认排序规则不符合需求时，可以通过传递自定义的比较器来实现定制化排序。常见的定制场景包括多字段排序、特殊规则排序等。
单字段定制排序
如果需要按照元素的某个自定义规则排序，比如按照字符串长度升序排列，可以传入对应的Comparator实现：
import java.util.Comparator;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class CustomSortedDemo {
public static void main(String[] args) {
List<String> sortedStrings = Stream.of("apple", "cat", "banana", "dog", "elephant")
// 传入自定义比较器，按照字符串长度升序排序
.sorted(Comparator.comparingInt(String::length))
.collect(Collectors.toList());
System.out.println(sortedStrings); // 输出 [cat, dog, apple, banana, elephant]
}
}
多字段定制排序
业务中经常需要按照多个字段排序，比如先按照用户年龄升序，年龄相同再按照用户姓名升序，可以通过thenComparing方法拼接比较规则：
import java.util.Comparator;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
class User {
private String name;
private int age;
public User(String name, int age) {
this.name = name;
this.age = age;
}
public String getName() {
return name;
}
public int getAge() {
return age;
}
@Override
public String toString() {
return "User{name='" + name + "', age=" + age + "}";
}
}
public class MultiFieldSortedDemo {
public static void main(String[] args) {
List<User> sortedUsers = Stream.of(
new User("张三", 20),
new User("李四", 18),
new User("王五", 20),
new User("赵六", 18)
)
// 先按年龄升序，年龄相同按姓名升序
.sorted(Comparator.comparingInt(User::getAge)
.thenComparing(User::getName))
.collect(Collectors.toList());
System.out.println(sortedUsers);
// 输出 [User{name='李四', age=18}, User{name='赵六', age=18}, User{name='张三', age=20}, User{name='王五', age=20}]
}
}
变量比较性能优化方案
流数据排序的性能瓶颈主要集中在元素比较环节，尤其是流数据量较大、比较逻辑复杂时，优化比较逻辑可以显著提升整体性能。
减少重复计算
如果比较过程中需要计算某个变量的衍生值，且该值不会变化，可以提前缓存计算结果，避免每次比较都重复计算。比如按照用户生日的年份排序，提前提取年份缓存：
import java.util.Calendar;
import java.util.Comparator;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
class UserWithBirth {
private String name;
private Date birthDate;
public UserWithBirth(String name, Date birthDate) {
this.name = name;
this.birthDate = birthDate;
}
public Date getBirthDate() {
return birthDate;
}
public String getName() {
return name;
}
}
public class CacheCompareDemo {
public static void main(String[] args) {
Calendar cal = Calendar.getInstance();
cal.set(2000, 0, 1);
Date birth1 = cal.getTime();
cal.set(1998, 5, 10);
Date birth2 = cal.getTime();
cal.set(2000, 2, 15);
Date birth3 = cal.getTime();
List<UserWithBirth> sortedUsers = Stream.of(
new UserWithBirth("张三", birth1),
new UserWithBirth("李四", birth2),
new UserWithBirth("王五", birth3)
)
// 提前提取年份作为比较键，避免每次比较都解析日期
.sorted(Comparator.comparingInt(user -> {
Calendar c = Calendar.getInstance();
c.setTime(user.getBirthDate());
return c.get(Calendar.YEAR);
}))
.collect(Collectors.toList());
System.out.println(sortedUsers.stream().map(UserWithBirth::getName).collect(Collectors.toList()));
// 输出 [李四, 张三, 王五]
}
}
简化比较逻辑
复杂的比较逻辑会增加单次比较的时间开销，尽量将比较逻辑简化为基础类型的数值比较。比如比较两个自定义对象的大小，优先提取可比较的数值字段，避免嵌套多层的对象调用。
避免无效比较
如果流数据本身已经部分有序，可以先进行预过滤或者预分组，减少需要参与排序的元素数量，从而减少比较次数。比如只需要取前10个最大的元素，可以先过滤掉明显小于当前候选值的元素，再执行排序。
注意事项
- sorted操作是中间操作，只有触发终端操作（如
collect、forEach）时才会实际执行排序逻辑，不会立即处理流数据。 - 对于并行流使用sorted操作时，需要注意比较器的线程安全性，避免比较过程中使用共享的可变变量。
- 如果流数据量极大，sorted操作会将所有元素加载到内存中进行排序，需要评估内存占用，必要时可以分批处理流数据。
定制化排序的核心是根据业务需求编写合理的比较规则，性能优化的核心是减少不必要的比较开销，两者结合可以在满足功能需求的同时保证处理效率。