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