code: private void lock_data() {
      source.read_lock(self());
      if( validation != null && source._key != null && validation._key !=null && !source._key.equals(validation._key) )
        validation.read_lock(self());
    }
docs: Lock the input datasets against deletes