我不认为你可以做得比 O(n) 时间复杂度更好 - 在最坏的情况下,你将不得不触摸数据集中的每个元素才能找到重复项
改善空间消耗的一种方法(以需要一些位旋转以及两次遍历数据集为代价)是使用Bloom Filter。这个想法是对数据集进行第一次传递:如果您发现可能的重复项,则将其从数据集中删除并将其添加到哈希表中(如果布隆过滤器功能正确,那么只有大约 1% 的元素会被标记尽可能重复)。然后对过滤后的数据集进行第二次遍历,根据可能重复的小哈希表测试元素。
我的代码将使用 Java,因为它是我最熟悉的语言。
Class DupFinder {
BloomFilter filter = new BloomFilter();
HashTable hashTable = new HashTable();
int start = 0;
int run(int[] dataset) {
// first pass
for(int i = 0; i < dataset.length; i++) {
if(filter.contains(dataset[i]) {
// check if element is in hashTable, else add it
if(hashTable.contains(dataset[i]) {
return dataset[i]; // duplicate found
} else {
hashTable.add(dataset[i]);
}
// remove element from dataset
int temp = dataset[start];
dataset[start] = dataset[i];
dataset[i] = temp;
start++;
} else filter.add(dataset[i]);
}
// second pass
for(int i = start; i < dataset.length; i++) {
if(hashTable.contains(dataset[i]) {
return dataset[i]; // duplicate found
}
}
return NULL; // no duplicate found
}
}
哈希表的替代方法是使用Radix Sort,这是一种线性时间排序算法。基数排序将具有更好的最坏情况性能(基数排序为 O(n),与哈希表的 O(n^2) 相比,在您遇到荒谬数量的冲突的不太可能的情况下)但平均情况性能较差(哈希表实现通常会在只扫描一半数据集后找到重复项,而基数排序总是需要对数据集进行多次遍历)。如果您为存储桶使用空间高效的数据结构,则基数排序在空间消耗方面也将稍微更有效,例如一个分块列表。
您可以并行化哈希表实现,而不会产生过多的同步开销。使用 t 个线程,每个线程将处理数据集的 n/t 个元素(例如,如果数据集中有 32 个元素和 2 个线程,则 thread0 处理元素 0-15 thread1 处理元素 16-31),将每个元素放入索引为 absoluteValue(x modulo t) 的桶中。在此之后,每个线程将负责处理具有给定存储桶索引的所有元素,例如thread0 将处理索引为 0 的所有存储桶。我使用 BlockingQueue 进行同步 - 这允许线程在队列上调用 take(),从而导致线程删除第一个元素排队或阻塞,直到元素可用;所有其他数据结构都是线程本地的。您需要初始化 dupFinders 变量,以便 DupFinder 实例出现在每个 DupFinder 的 dupFinders 变量的相同索引中(例如 thread0 始终出现在第 0 个索引中,从而确保其 BlockingQueue 中的所有元素都具有 absoluteValue(x modulo t) == 0).
Class DupFinder implements Callable<Integer> {
private Class Chunk {
int size = 0;
int chunk = new int[64];
boolean add(int x) {
if(size < 64) {
chunk[size] = x;
size++;
return true;
} else return false;
}
}
int t = ??? // number of threads
private BlockingQueue<Stack<Chunk>> queue = new LinkedBlockingQueue()
private DupFinder[] dupFinders = new DupFinder[t];
private Stack<Chunk>[] stacks = new Stack<Chunk>[t];
void add(Stack<Chunk> stack) {
queue.add(stack);
}
// the thread only receives n/t elements of the dataset
int call(int[] partialDataset) {
// partition dataset elements by their modulus(t)
for(int i = 0; i < partialDataset.length; i++) {
tempStack = stacks[Math.absoluteValue(partialDataset[i] modulo t)];
if(!tempStack.peek().add(partialDataset[i])) {
Chunk chunk = new Chunk();
chunk.add(partialDataset[i]);
tempStack.push(chunk);
}
}
// distribute chunk stacks to the appropriate threads
for(int i = 0; i < t; i++) {
dupFinders[i].add(stacks[i]);
}
HashTable hashTable = new HashTable();
for(int i = 0; i < t; i++) {
// wait for a chunk stack to become available
Stack<Chunk> tempStack = queue.take();
while(!tempStack.isEmpty) {
tempChunk = tempStack.pop();
for(int i = 0; i < tempChunk.size; i++) {
if(hashTable.contains(tempChunk.chunk[i]) {
return tempChunk.chunk[i]; // duplicate found
} else {
hashTable.add(tempChunk.chunk[i]);
}
}
}
}
return NULL; // no duplicate found
}
}