Skip to main content
2 de 2
comparator
brow-joe
  • 2,2mil
  • 8
  • 15

Você pode trabalhar com o ConcurrentSkipListSet, ele trabalhar igual ao Set porém é apropriado a trabalhar em multithreads e também mais seguro com relação a ordem dos dados, segue um exemplo

// Define a ordem
Comparator sort = Collections.reverseOrder();
// Cria a collection
Collection<Double> precos = new ConcurrentSkipListSet<>(sort);

// Teste crio um pool com 100 threads onde cada thread adiciona dentro
// da lista um valor aleatório
ExecutorService pool = Executors.newFixedThreadPool(100);
for (int i = 0; i < 300000; i++) {
    pool.submit(() -> {
        precos.add(Math.random());
    });

}

// Finaliza o pool
pool.shutdown();
System.out.println("Done!");

// Exibe o top 10
int index = 1;
for (double p : precos) {
    System.out.println(p);
    if (index++ == 10) {
        break;
    }
}

Veja que ao final do processo a collection de preços tem todos os dados que as threads adicionaram de forma aleatória ordenados.

A ordem por padrão é crescente (Construtor vazio) mais você pode colocar de ordem decrescente ou personalizar seu comparator passando no construtor do ConcurrentSkipListSet, exemplo:

Comparator sort = new Comparator<Double>() {
    @Override
    public int compare(Double o1, Double o2) {
        return Double.compare(o1, o2);
    }
};

Neste caso basta você adaptar o comparator para trabalhar conforme as especificacoes do EDIT. 2: de seu código

brow-joe
  • 2,2mil
  • 8
  • 15