ddustin

    vector<condition_variable_any*> waiters;

    vector<condition_variable_any*>::iterator it;
    for (it = m_array[index].waiters.begin();
         it != m_array[index].waiters.end();
         ++it) {
      (*it)->notify_one();
    }

    map<int, map<int, int>> equalityIndices;
    map<int, pair<mutex, condition_variable> pendingWaits;
    mutex writeLock;

    writeLock.lock();
    
    mutex *m;
    condition_variable *cv;
    
    if(pendingWaits.count(index1)) {
        m = &pendingWaits[index1].first;
        cv = &pendingWaits[index1].second;
    }
    else {
        m = &pendingWaits[index2].first;
        cv = &pendingWaits[index2].second;
    }
    
    equalityIndices[index1][index2]++;
    equalityIndices[index2][index1]++;
    
    writeLock.unlock();
    
    unique_lock lk(*m);
    
    do {
        cv->wait(lk);
    } while(array[index1] != array[index2]);
    
    writeLock.lock();
    
    if(--equalityIndices[index1][index2] == 0) {
        equalityIndices[index1].erase(index2);
        if(equalityIndices[index1].empty()) {
            equalityIndices.erase(index1);
            pendingWaits.erase(index1);
        }
    }
    
    if(--equalityIndices[index2][index1] == 0) {
        equalityIndices[index2].erase(index1);
        if(equalityIndices[index2].empty()) {
            equalityIndices.erase(index2);
            pendingWaits.erase(index2);
        }
    }
    
    writeLock.unlock();

    array[index] = value;
    
    if(equalityIndices.count(index)) {
        pendingWaits[index].second.notify_all();
        try {
            for(const auto itr : equalityIndices.at(index))
                if(array[index] == array[*itr])
                    pendingWaits[*itr].second.notify_all();
        }
        catch(out_of_range e) {
            (void)e;
        }
    }