rebalance

rebalance a heap

⑴最大堆的插入

由于需要维持完全二叉树的形态,需要先将要插入的结点x放在最底层的最右边,插入后满 足完全二叉树的特点; 
  然后把x依次向上调整到合适位置满足堆的性质,例如下图中插入80,先将80放在最后,然后两次上浮到合适位置. 
  时间:O(logn)。  “结点上浮” 

程序实现:
 //向最大堆中插入元素, heap:存放堆元素的数组
    public static void insert(List<Integer> heap, int value) {
       //在数组的尾部添加
        if(heap.size()==0)
          heap.add(0);//数组下标为0的位置不放元素
        heap.add(value);
        //开始上升操作
       // heapUp2(heap, heap.size() - 1);
        heapUp(heap, heap.size() - 1); 

    } 

    //上升,让插入的数和父节点的数值比较,当大于父节点的时候就和父节点的值相交换
    public static void heapUp(List<Integer> heap, int index) { 

        //注意由于数值是从下标为1开始,当index = 1的时候,已经是根节点了
        if (index > 1) {
            //求出父亲的节点
            int parent = index / 2; 

            //获取相应位置的数值
            int parentValue = (Integer) heap.get(parent);
            int indexValue = (Integer) heap.get(index);
            //如果父亲节点比index的数值小,就交换二者的数值
            if (parentValue < indexValue) {
                //交换数值
                swap(heap, parent, index);
                //递归调用
                heapUp(heap, parent);
            } 

        }
    } 

⑵删除 
   操作原理是:当删除节点的数值时,原来的位置就会出现一个孔,填充这个孔的方法就是, 
把最后的叶子的值赋给该孔并下调到合适位置,最后把该叶子删除。 
  
如图中要删除72,先用堆中最后一个元素来35替换72,再将35下沉到合适位置,最后将叶子节点删除。 
   “结点下沉”

程序:
 /**
     * 删除堆中位置是index处的节点
     * 操作原理是:当删除节点的数值时,原来的位置就会出现一个孔
     * 填充这个孔的方法就是,把最后的叶子的值赋给该孔,最后把该叶子删除
     * @param heap
     */
    public static void delete(List<Integer> heap,int index) {
        //把最后的一个叶子的数值赋值给index位置
        heap.set(index, heap.get(heap.size() - 1));
        //下沉操作
        //heapDown2(heap, index);
        heapDown(heap, index);
        //把最后一个位置的数字删除
        heap.remove(heap.size() - 1);
    }
    /**
     * 递归实现
     * 删除堆中一个数据的时候,根据堆的性质,应该把相应的位置下移,才能保持住堆性质不变
     * @param heap 保持堆元素的数组
     * @param index 被删除的那个节点的位置
     */
    public static void heapDown(List<Integer> heap, int index) {
        //因为第一个位置存储的是空值,不在考虑之内
        int n = heap.size() - 2; 

        //记录最大的那个儿子节点的位置
        int child = -1; 

        //2*index>n说明该节点没有左右儿子节点了,那么就返回
        if (2 * index > n) {
            return;
        } //如果左右儿子都存在
        else if (2 * index < n) { 

            //定义左儿子节点
            child = 2 * index;
            //如果左儿子小于右儿子的数值,取右儿子的下标
            if ((Integer) heap.get(child) < (Integer) heap.get(child + 1)) {
                child++;
            } 

        }//如果只有一个儿子(左儿子节点)
        else if (2 * index == n) {
            child = 2 * index;
        } 

        if ((Integer) heap.get(child) > (Integer) heap.get(index)) {
            //交换堆中的child,和index位置的值
            swap(heap, child, index); 

            //完成交换后递归调用,继续下降
            heapDown(heap, child);
        }
    }
 
时间: 2024-09-17 09:25:31

rebalance的相关文章

Kafka 0.11版本新功能介绍 —— 空消费组延时rebalance

在0.11之前的版本中,多个consumer实例加入到一个空消费组将导致多次的rebalance,这是由于每个consumer instance启动的时间不可控,很有可能超出coordinator确定的rebalance timeout(即max.poll.interval.ms),而每次rebalance的代价又相当地大,因为很多状态都需要在rebalance前被持久化,而在rebalance后被重新初始化.曾经有个国外用户,他有100个consumer,每次rebalance的时间甚至要1个

OpenStack_Swift源码分析——Ring的rebalance算法源代码详细分析

今天有同学去百度,带回一道面试题,和大家分享一下: 打印: n=1 1 n=2 3 3 2 4 1 1 4 5 5 n=3 7 7 7 7 6 8 3 3 2 6 8 4 1 1 6 8 4 5 5 5 8 9 9 9 9 提供一段参考程序: <pre name="code" class="cpp">// ConsoleApplication1.cpp: 主项目文件. #include "stdafx.h" #include &quo

Storm一个executor里运行多个task是为了rebalance

默认情况下下,一个executor运行一个component,即一个task,但有时会指定多个task: 1 builder.setBolt("", new XxBolt()).setNumTasks(2); 这是为了rebalance命令.

12C对ASM rebalance操作的优化

如果在执行"alter diskgroup"操作.或在添加.删除磁盘而引发的隐式rebalance的时,没有指定power选项,rebalance操作会使用初始化参数asm_power_limit的值. 这个参数的值可以动态调整.power选项的值越高,rebalance操作越快,但消耗的I/O资源也相对较多. 12c 中新的explain work for 语句用于衡量一个给定asm rebalance操作所需的工作量, 并在v$asm_estimate动态视图中输入结果,其中est

glusterfs rebalance

# gluster volume rebalance VOLNAME start # gluster volume rebalance VOLNAME status # gluster volume rebalance VOLNAME stop http://gluster.readthedocs.org/en/release-3.7.0beta1/Features/dht/ http://my.oschina.net/uvwxyz/blog/182224

Rebalance Customer Balances Utility的使用

用户不管是打开A/R Posted Transactions Detail还是A/R Posted Transactions Summary 窗口,均显示如下一个警示: 打开Currency Codes窗口,检查decimal显示格式,均已经设为最大长度,说明与此无关. 后来,找到一个Utility,Modules >> Customer >> General >> Utilities >> Rebalance Customer Balances: Reba

glusterfs Self-Heal and Re-Balance Operations

In my previous article on ' Introduction to GlusterFS (File System) and Installation – Part 1' was just a brief overview of the file system and its advantages describing some basic commands. It is worth mentioning about the two important features,  

memcached源码分析-----slab automove和slab rebalance

        转载请注明出处:http://blog.csdn.net/luotuo44/article/details/43015129 需求: 考虑这样的一个情景:在一开始,由于业务原因向memcached存储大量长度为1KB的数据,也就是说memcached服务器进程里面有很多大小为1KB的item.现在由于业务调整需要存储大量10KB的数据,并且很少使用1KB的那些数据了.由于数据越来越多,内存开始吃紧.大小为10KB的那些item频繁访问,并且由于内存不够需要使用LRU淘汰一些10K

kafka一直rebalance故障,重复消费

今天我司线上kafka消息代理出现错误日志,异常rebalance,而且平均间隔2到3分钟就会rebalance一次,分析日志发现比较严重.错误日志如下 08-09 11:01:11 131 pool-7-thread-3 ERROR [] - commit failed org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be completed since the group has already r