CVPR论文《100+ Times Faster Weighted Median Filter (WMF)》的实现和解析(附源代码)。

  四年前第一次看到《100+ Times FasterWeighted Median Filter (WMF)》一文时,由于他附带了源代码,并且仍是CVPR论文,所以,当时也对代码进行了必定的整理和解读,可是当时以为这个算法虽然对原始速度有很多的提升,可是仍是比较慢。所以,没有怎么在乎,这几天有几位朋友又提到这篇文章,因而把当时的代码和论文又仔细的研读了一番,对论文的思想和其中的实现也有了一些新的新的,再次作个总结和分享。html

  这篇文章的官网地址是:http://www.cse.cuhk.edu.hk/~leojia/projects/fastwmedian/,其中主要做者Jiaya Jia教授的官网地址是:http://jiaya.me/,根据Jiaya Jia的说法,这个算法很快将被OpenCv所收录,到时候OpenCv的大神应该对他还有所改进吧。算法

  在百度上搜索加权中值模糊,彷佛只有一篇博客对这个文章进行了简单的描述,详见:https://blog.csdn.net/streamchuanxi/article/details/79573302?utm_source=blogxgwz9数据结构

  因为做者只给出了最后的优化实现代码,而论文中还提出了各类中间过程的时间,所以本文以实现和验证论文中有关说法为主,涉及到的理论知识比较肤浅,通常是一笔而过。ide

  根据论文中得说法,所谓的加权中值滤波,也是一种非线性的图像平滑技术,他取一个局部窗口内全部像素的加权中值来代替局部窗口的中心点的值。用较为数学的方法表示以下:函数

  在图像I中的像素p,咱们考虑以p为中心,半径为R的局部窗口,不一样于普通的中值模糊,对于属于内每个像素q,都有一个基于对应的特征图像的类似度的权重系数wpq,以下式所示:布局

                           

  f(p)和f(q)是像素p和q在对应的特征图中得特征值。g是一个权重函数,最经常使用的即为高斯函数,反应了像素p和q的类似程度。post

  咱们用I(q)表示像素点q的像素值,在窗口内的像素总数量用n表示,则n=(2r+1)*(2r+1),那么窗口内像素值和权重值构成一个对序列,即,对这个序列按照I(q)的值进行排序。排序后,咱们依次累加权重值,直到累加的权重大于等于全部权重值的一半时中止,此时对应的I(q)即做为本局部窗口中心点的新的像素值。性能

                               

  很明显,上面的过程要比标准的中值模糊复杂一些,在处理时多了特征图和权重函数项,而标准的中值模糊咱们能够认为是加权中值模糊的特例,即全部局部窗口的权重都为1或者说相等。测试

  在这里,特征图能够直接是源图像,也能够是其余的一些特征,好比原图像的边缘检测结果、局部均方差、局部熵或者其余的更为高级的特征。优化

  按照这个定义,咱们给出一段针对灰度数据的Brute-force处理代码:

int __cdecl ComparisonFunction(const void *X, const void *Y)        // 必定要用__cdecl这个标识符
{ Value_Weight VWX = *(Value_Weight *)X; Value_Weight VWY = *(Value_Weight *)Y; if (VWX.Value < VWY.Value) return -1; else if (VWX.Value > VWY.Value) return +1; else
        return 0; } // 加权中值模糊,直接按照算法的定义实现。 // Input - 输入图像,灰度图,LevelV = 256级 // FeatureMap - 特征图像,灰度图,LevelF = 256级 // Weight - 特征的权重矩阵,大小是LevelF * LevelF // Output - 输出图像,不能和Input为同一个数据。

int IM_WeightedMedianBlur_00(unsigned char *Input, unsigned char *FeatureMap, float *Weight, unsigned char *Output, int Width, int Height, int Stride, int Radius) { int Channel = Stride / Width; if ((Input == NULL) || (Output == NULL))                                        return IM_STATUS_NULLREFRENCE; if ((FeatureMap == NULL) || (Weight == NULL))                                    return IM_STATUS_NULLREFRENCE; if ((Width <= 0) || (Height <= 0) || (Radius <= 0))                              return IM_STATUS_INVALIDPARAMETER; if ((Channel != 1))                                                      return IM_STATUS_NOTSUPPORTED; const int LevelV = 256;                // Value 可能出现的不一样数量
    const int LevelF = 256;                // Feature 可能出现的不一样数量
 Value_Weight *VW = (Value_Weight *)malloc((2 * Radius + 1) * (2 * Radius + 1) * sizeof(Value_Weight));            // 值和特征序列对内存
    if (VW == NULL)    return IM_STATUS_OK; for (int Y = 0; Y < Height; Y++) { unsigned char *LinePF = FeatureMap + Y * Stride; unsigned char *LinePD = Output + Y * Stride; for (int X = 0; X < Width; X++) { int CF_Index = LinePF[X] * LevelF; int PixelAmount = 0; float SumW = 0; for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++) { int Index = J * Stride; for (int I = IM_Max(X - Radius, 0); I <= IM_Min(X + Radius, Width - 1); I++)        // 注意越界
 { int Value = Input[Index + I];                            //
                    int Feature = FeatureMap[Index  + I];                    // 特征
                    float CurWeight = Weight[CF_Index + Feature];            // 对应的权重
                    VW[PixelAmount].Value = Value; VW[PixelAmount].Weight = CurWeight;                        // 保存数据
                    SumW += CurWeight;                                        // 计算累加数据
                    PixelAmount++;                                            // 有效的数据量 
 } } float HalfSumW = SumW * 0.5f;                                    // 一半的权重
            SumW = 0; qsort(VW, PixelAmount, sizeof VW[0], &ComparisonFunction);        // 调用系统的qsort按照Value的值从小到大排序,注意qsort的结果仍然保存在第一个参数中
            for (int I = 0; I < PixelAmount; I++)                            // 计算中值
 { SumW += VW[I].Weight; if (SumW >= HalfSumW) { LinePD[X] = VW[I].Value; break; } } } } free(VW); return IM_STATUS_OK; }

  很明显,这个函数的时间复杂度是o(radius * radius),空间复杂度到时很小。

  咱们在一台 I5,3.3GHZ的机器上进行了测试,上述代码处理一副1000*1000像素的灰度图,半径为10(窗口大小21*21)时,处理时间约为27s,论文里给的Cpu和个人差很少,给出的处理one - metalpixel的RGB图用时90.7s,考虑到RGB的通道的数据量以及一些其余的处理,应该说论文如实汇报了测试数据。

  那么从代码优化上面讲,上面代码虽然还有优化的地方,可是都是小打小闹了。使用VS的性能分析器,能够大概得到以下的结果:

       

  可见核心代码基本都用于排序了,使用更快的排序有助于进一步提升速度。

  针对这个状况,论文的做者从多方面提出了改进措施,主要有三个方面,咱们简单的重复下。

  1、联合直方图(Joint Histgram)

  直方图优化在不少算法中都有应用,好比标准的中值滤波,如今看到的最快的实现方式仍是基于直方图的,详见:任意半径中值滤波(扩展至百分比滤波器)O(1)时间复杂度算法的原理、实现及效果,可是在加权中值滤波中,传统的一维直方图已经没法应用,由于这个算法不只涉及到原图的像素值,还和另一幅特征图有关,所以,文中提出了联合直方图,也是一种二维直方图。

  若是图像中的像素最多有LevelV个不一样值,其对应的特征最多有LevelF个不一样的值,那么咱们定义一个宽和高分别为LevelV * LevelF大小的直方图。对于某一个窗口,统计其内部的(2r+1)*(2r+1)个像素和特征对的直方图数据,即若是某个点的像素值为V,对应的特征值为F,则相应位置的直方图数据加1。

  若是咱们统计出这个二维的直方图数据后,因为中心点的特征值是固定的,所以,对于直方图的每个LevelF值,权重是必定的了,咱们只需计算出直方图内每个Value值所对应全部的Feature的权重后,就可方便的统计出中值所在的位置了。

  那么若是每一个像素点都进行领域直方图的计算,这个的工做量也是蛮大的,同一维直方图的优化思路同样,在进行逐像素行处理的时候,对直方图数据能够进行逐步的更新,去除掉移走的那一列的直方图信息,在加入即将进入那一列数据,而中间重叠部分则不须要调整。

  按照论文中的Joint Histgram的布局,即行方向大小为LevelV,列方向大小为LevelF,编制Joint Histgram实现的加权中值算法代码以下所示:

// 加权中值模糊,基于论文中图示的内存布局设置的Joint Histgram。 
int IM_WeightedMedianBlur_01(unsigned char *Input, unsigned char *FeatureMap, float *Weight, unsigned char *Output, int Width, int Height, int Stride, int Radius) { int Channel = Stride / Width; if ((Input == NULL) || (Output == NULL))                                        return IM_STATUS_NULLREFRENCE; if ((FeatureMap == NULL) || (Weight == NULL))                                    return IM_STATUS_NULLREFRENCE; if ((Width <= 0) || (Height <= 0) || (Radius <= 0))                                return IM_STATUS_INVALIDPARAMETER; if ((Channel != 1) && (Channel != 3))                                            return IM_STATUS_NOTSUPPORTED; int Status = IM_STATUS_OK; const int LevelV = 256;                // Value 可能出现的不一样数量
    const int LevelF = 256;                // Feature 可能出现的不一样数量

    int *Histgram = (int *)malloc(LevelF * LevelV * sizeof(int)); float *Sum = (float *)malloc(LevelV * sizeof(float)); if ((Histgram == NULL) || (Sum == NULL)) { Status = IM_STATUS_OUTOFMEMORY; goto FreeMemory; } for (int Y = 0; Y < Height; Y++) { unsigned char *LinePF = FeatureMap + Y * Stride; unsigned char *LinePD = Output + Y * Stride; memset(Histgram, 0, LevelF * LevelV * sizeof(int)); for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++) { for (int I = IM_Max(0 - Radius, 0); I <= IM_Min(0 + Radius, Width - 1); I++) { int Value = Input[J * Stride + I]; int Feature = FeatureMap[J * Stride + I];        // 统计二维直方图
                Histgram[Feature * LevelV + Value]++; } } for (int X = 0; X < Width; X++) { int Feature = LinePF[X]; float SumW = 0, HalfSumW = 0;; for (int I = 0; I < LevelV; I++) { float Cum = 0; for (int J = 0; J < LevelF; J++)        // 计算每一个Value列针对的不一样的Feature的权重的累计值
 { Cum += Histgram[J * LevelV + I] * Weight[J * LevelF + Feature]; } Sum[I] = Cum; SumW += Cum; } HalfSumW = SumW / 2; SumW = 0; for (int I = 0; I < LevelV; I++) { SumW += Sum[I]; if (SumW >= HalfSumW)                // 计算中值
 { LinePD[X] = I; break; } } if ((X - Radius) >= 0)                    // 移出的那一列的直方图
 { for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++) { int Value = Input[J * Stride + X - Radius]; int Feature = FeatureMap[J * Stride + X - Radius]; Histgram[Feature * LevelV + Value]--; } } if ((X + Radius + 1) <= Width - 1)        // 移入的那一列的直方图
 { for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++) { int Value = Input[J * Stride + X + Radius + 1]; int Feature = FeatureMap[J * Stride + X + Radius + 1]; Histgram[Feature * LevelV + Value]++; } } } } FreeMemory: if (Histgram != NULL) free(Histgram); if (Sum != NULL) free(Sum); return Status; }

  编译后测试,一样是21*21的窗口,one - metalpixel的灰度图像计算用时多达108s,比直接实现慢不少了。

  分析缘由,核心就是在中值的查找上,因为咱们采用的内存布局方式,致使计算每一个Value对应的权重累加存在的大量的Cache miss现象,即下面这条语句:

for (int J = 0; J < LevelF; J++)        //    计算每一个Value列针对的不一样的Feature的权重的累计值
{
    Cum += Histgram[J * LevelV + I] * Weight[J * LevelF + Feature];
}

  咱们换种Joint Histgram的布局,即行方向大小为LevelF,列方向大小为LevelV,此时的代码以下:

//    加权中值模糊,修改内存布局设置的Joint Histgram。 
int IM_WeightedMedianBlur_02(unsigned char *Input, unsigned char *FeatureMap, float *Weight, unsigned char *Output, int Width, int Height, int Stride, int Radius)
{
    int Channel = Stride / Width;
    if ((Input == NULL) || (Output == NULL))                                        return IM_STATUS_NULLREFRENCE;
    if ((FeatureMap == NULL) || (Weight == NULL))                                    return IM_STATUS_NULLREFRENCE;
    if ((Width <= 0) || (Height <= 0) || (Radius <= 0))                                return IM_STATUS_INVALIDPARAMETER;
    if ((Channel != 1) && (Channel != 3))                                            return IM_STATUS_NOTSUPPORTED;
    int Status = IM_STATUS_OK;

    const int LevelV = 256;                //    Value 可能出现的不一样数量
    const int LevelF = 256;                //    Feature 可能出现的不一样数量

    int *Histgram = (int *)malloc(LevelF * LevelV * sizeof(int));
    float *Sum = (float *)malloc(LevelV * sizeof(float));
    if ((Histgram == NULL) || (Sum == NULL))
    {
        Status = IM_STATUS_OUTOFMEMORY;
        goto FreeMemory;
    }
    for (int Y = 0; Y < Height; Y++)
    {
        unsigned char *LinePF = FeatureMap + Y * Stride;
        unsigned char *LinePD = Output + Y * Stride;
        memset(Histgram, 0, LevelF * LevelV * sizeof(int));
        for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
        {
            int Index = J * Stride;
            for (int I = IM_Max(0 - Radius, 0); I <= IM_Min(0 + Radius, Width - 1); I++)
            {
                int Value = Input[J * Stride + I];
                int Feature = FeatureMap[J * Stride + I];
                Histgram[Value * LevelF + Feature]++;            //    注意索引的方式的不一样
            }
        }
        for (int X = 0; X < Width; X++)
        {
            int IndexF = LinePF[X] * LevelF;
            float SumW = 0, HalfSumW = 0;;
            for (int I = 0; I < LevelV; I++)
            {
                float Cum = 0;
                int Index = I * LevelF;
                for (int J = 0; J < LevelF; J++)        //    核心就这里不一样
                {
                    Cum += Histgram[Index + J] * Weight[IndexF + J];
                }
                Sum[I] = Cum;
                SumW += Cum;
            }
            HalfSumW = SumW / 2;
            SumW = 0;
            for (int I = 0; I < LevelV; I++)
            {
                SumW += Sum[I];
                if (SumW >= HalfSumW)
                {
                    LinePD[X] = I;
                    break;
                }
            }
            if ((X - Radius) >= 0)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    int Value = Input[J * Stride + X - Radius];
                    int Feature = FeatureMap[J * Stride + X - Radius];
                    Histgram[Value * LevelF + Feature]--;
                }
            }
            if ((X + Radius + 1) <= Width - 1)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    int Value = Input[J * Stride + X + Radius + 1];
                    int Feature = FeatureMap[J * Stride + X + Radius + 1];
                    Histgram[Value * LevelF + Feature]++;
                }
            }
        }
    }
FreeMemory:
    if (Histgram != NULL)    free(Histgram);
    if (Sum != NULL)        free(Sum);
    return Status;
}

  修改后,一样的测试条件和图片,速度提高到了17s,仅仅是更改了一个内存布局而已,原论文的图没有采用这种布局方式,也许只是为了表达算法清晰而已。

  和原论文比较,原论文的joint histgram时间要比直接实现慢(156.9s vs 90.7s),而我这里的一个版本比brute force的快,一个比brute force的慢,所以,不清楚做者在比较时采用了何种编码方式,可是这都不重要,由于他们的区别都还在一个数量级上。

       因为直方图大小是固定的,所以,前面的中值查找的时间复杂度是固定的,然后续的直方图更新则是o(r)的,可是注意到因为LevelV和 LevelF一般都是比较大的常数(通常为256),所以实际上,中值查找这一块的耗时占了绝对的比例。

 2、快速中值追踪

  寻找中值的过程实际上能够当作一个追求平衡的过程,假定当前搜索到的位置是V,位于V左侧全部相关值的和是Wl,位于V右侧全部相关值得和是Wr,则中值的寻找能够认为是下式:

                          

  后面的约束条件能够理解为第一次出现Wl大于Wr前。

       若是咱们以前已经寻找到了像素P处的中值,那么因为像素的连续性,像素P+1处的中值通常不会和P处的中值差别太大,大量的统计数据代表他们的差别基本在8个像素值之类(256色阶图),那么这个思想其实和任意半径中值滤波(扩展至百分比滤波器)O(1)时间复杂度算法的原理、实现及效果中讲到的是一致的。这种特性,咱们也能够将他运用到加权中值滤波中。

  考虑到加权中值滤波中联合直方图的特殊性,咱们须要维护一张平衡表,论文中叫作Balance Counting Box(BCB),这一块的解释比较拗口也比较晦涩,你们须要仔细的看论文和我下面提供的JointHist+MedianTracking代码。

//    加权中值模糊, Joint + MT
int IM_WeightedMedianBlur_03(unsigned char *Input, unsigned char *FeatureMap, float *Weight, unsigned char *Output, int Width, int Height, int Stride, int Radius)
{
    int Channel = Stride / Width;
    if ((Input == NULL) || (Output == NULL))                                        return IM_STATUS_NULLREFRENCE;
    if ((FeatureMap == NULL) || (Weight == NULL))                                    return IM_STATUS_NULLREFRENCE;
    if ((Width <= 0) || (Height <= 0) || (Radius <= 0))                                return IM_STATUS_INVALIDPARAMETER;
    if ((Channel != 1) && (Channel != 3))                                            return IM_STATUS_NOTSUPPORTED;
    int Status = IM_STATUS_OK;

    const int LevelV = 256;                //    Value 可能出现的不一样数量
    const int LevelF = 256;                //    Feature 可能出现的不一样数量

    int *Histgram = (int *)malloc(LevelF * LevelV * sizeof(int));
    int *BCB = (int *)malloc(LevelF * sizeof(int));

    if ((Histgram == NULL) || (BCB == NULL))
    {
        Status = IM_STATUS_OK;
        return IM_STATUS_OUTOFMEMORY;
    }

    for (int Y = 0; Y < Height; Y++)
    {
        unsigned char *LinePF = FeatureMap + Y * Stride;
        unsigned char *LinePD = Output + Y * Stride;
        memset(Histgram, 0, LevelF * LevelV * sizeof(int));                        //    所有赋值为0
        memset(BCB, 0, LevelF * sizeof(int));
        int CutPoint = -1;
        for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
        {
            int Index = J * Stride;
            for (int I = IM_Max(0 - Radius, 0); I <= IM_Min(0 + Radius, Width - 1); I++)
            {
                int Value = Input[J * Stride + I];
                int Feature = FeatureMap[J * Stride + I];
                Histgram[Value * LevelF + Feature]++;    //    计算每行第一个点的二维直方图,直方图的水平方向为Feature坐标,垂直方向为Value坐标    
                BCB[Feature]--;                            //    此时的CutPoint初始化为-1,因此+方向的数据为0,全部的都在-方向        
            }
        }

        for (int X = 0; X < Width; X++)
        {
            float BalanceWeight = 0;
            int IndexF = LinePF[X] * LevelF;                                    //    中心点P的Value所对应的那一行Feature权重起始索引
            for (int I = 0; I < LevelF; I++)                                    //    BCB[I]中保存的是以CutPoint为分界线,Feature为I时,分界线左侧的全部Value[0-CutPoint]值的数量和分界线右侧全部的Value(CutPoint, LevelV - 1]值数量的差别
            {
                BalanceWeight += BCB[I] * Weight[IndexF + I];                    //    由于Feature为固定值时,若是中心点固定,那么无论与Feature对应的Value值时多少,Weight就是定值了。
            }
            if (BalanceWeight < 0)                                                //    第一个点的BalanceWeight必然小于0
            {
                for (; BalanceWeight < 0 && CutPoint != LevelV - 1; CutPoint++)
                {
                    int IndexH = (CutPoint + 1) * LevelF;                        //    新的直方图的位置
                    float CurWeight = 0;
                    for (int I = 0; I < LevelF; I++)
                    {
                        CurWeight += 2 * Histgram[IndexH + I] * Weight[IndexF + I];        //    左侧加右侧同时减,因此是2倍
                        BCB[I] += Histgram[IndexH + I] * 2;                        //    数量是一样的道理
                    }
                    BalanceWeight += CurWeight;
                }
            }
            else if (BalanceWeight > 0)                                    //    若是平衡值大于0,则向左移动中间值
            {
                for (; BalanceWeight > 0 && CutPoint != 0; CutPoint--)
                {
                    int IndexH = CutPoint * LevelF;
                    float CurWeight = 0;
                    for (int I = 0; I < LevelF; I++)
                    {
                        CurWeight += 2 * Histgram[IndexH + I] * Weight[IndexF + I];
                        BCB[I] -= Histgram[IndexH + I] * 2;
                    }

                    BalanceWeight -= CurWeight;
                }
            }
            LinePD[X] = CutPoint;

            if ((X - Radius) >= 0)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)        //    即将移出的那一列数据
                {
                    int Value = Input[J * Stride + X - Radius];
                    int Feature = FeatureMap[J * Stride + X - Radius];
                    Histgram[Value * LevelF + Feature]--;
                    if (Value <= CutPoint)                        //    若是移出的那个值小于当前的中值
                        BCB[Feature]--;
                    else
                        BCB[Feature]++;
                }
            }
            if ((X + Radius + 1) <= Width - 1)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    int Value = Input[J * Stride + X + Radius + 1];
                    int Feature = FeatureMap[J * Stride + X + Radius + 1];
                    Histgram[Value * LevelF + Feature]++;
                    if (Value <= CutPoint)                        //    若是移出的那个值小于当前的中值
                        BCB[Feature]++;
                    else
                        BCB[Feature]--;
                }
            }
        }
    }
    free(Histgram);
    free(BCB);
}

  代码也很简洁,主要是增长了一个BCB列表的维护,编译后测试,一样是21*21的窗口,one - metalpixel的灰度图像计算用420ms左右,比Brute-force版本的27s大约快了64倍,这个和论文的时间比例基本差很少((156.9+0.4)/(2.2+0.5)=58)。提速也是至关的可观,并且算法速度和半径不是特别敏感,毕竟更新直方图的计算量在这里占的比例其实已经很少了。

  3、Necklace Table

    那么论文最后还提出了另外的进一步加速的方案,这是基于如下观察到的事实,即在直方图的数据中,存在大量的0值,这些值的计算其实对算法自己是没有任何做用的,可是占用了大量的计算时间。

    

  好比上图是某个图像局部窗口的联合直方图和BCB值,在联合直方图中大部分区域都是0值对应的黑色,在BCB中大部分状况也是0值。

       所以,做者构建了一个叫作Necklace Table的数据结构,这个数据结构能够方便快捷的记录下一个和上一个非0元素的位置,从而能有效的访问到那些真正有计算价值的部位,以及简单的删除和增长节点的功能,具体的实现细节详见论文或下面的JointHistgram + Necklace Table代码。

int IM_WeightedMedianBlur_04(unsigned char *Input, unsigned char *FeatureMap, float *Weight, unsigned char *Output, int Width, int Height, int Stride, int Radius)
{
    int Channel = Stride / Width;
    if ((Input == NULL) || (Output == NULL))                                        return IM_STATUS_NULLREFRENCE;
    if ((FeatureMap == NULL) || (Weight == NULL))                                    return IM_STATUS_NULLREFRENCE;
    if ((Width <= 0) || (Height <= 0) || (Radius <= 0))                                return IM_STATUS_INVALIDPARAMETER;
    if ((Channel != 1) && (Channel != 3))                                            return IM_STATUS_NOTSUPPORTED;
    int Status = IM_STATUS_OK;

    const int LevelV = 256;                //    Value 可能出现的不一样数量
    const int LevelF = 256;                //    Feature 可能出现的不一样数量    const int LevelV = 256;
    
    int *Histgram = (int *)malloc(LevelF * LevelV * sizeof(int));
    int *ForwardH = (int *)malloc(LevelF * LevelV * sizeof(int));            //    forward link for necklace table
    int *BackWordH = (int *)malloc(LevelF * LevelV * sizeof(int));            //    forward link for necklace table
    float *Sum = (float *)malloc(LevelV * sizeof(float));
    if ((Histgram == NULL) || (ForwardH == NULL) || (BackWordH == NULL) || (Sum == NULL))
    {
        Status = IM_STATUS_OK;
        goto FreeMemory;
    }

    memset(ForwardH, 0, LevelF * LevelV * sizeof(int));
    memset(BackWordH, 0, LevelF * LevelV * sizeof(int));

    for (int Y = 0; Y < Height; Y++)
    {
        unsigned char *LinePF = FeatureMap + Y * Stride;
        unsigned char *LinePD = Output + Y * Stride;
        memset(Histgram, 0, LevelF * LevelV * sizeof(int));

        for (int X = 0; X < LevelV; X++)
        {
            ForwardH[X * LevelF] = 0;            //    其实每个Feature对应一个完整的Necklace Table,须要把第一个元素置为0
            BackWordH[X * LevelF] = 0;
        }
        for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)    //    第一个元素
        {
            int Index = J * Stride;
            for (int I = IM_Max(0 - Radius, 0); I <= IM_Min(0 + Radius, Width - 1); I++)
            {
                int Value = Input[Index + I];
                int Feature = FeatureMap[Index + I];
                int Index = Value * LevelF;
                if (Histgram[Index + Feature] == 0 && Feature != 0)        // 直方图数据若是仍是0而且FMap值不为0
                {
                    int T = ForwardH[Index];
                    ForwardH[Index] = Feature;
                    ForwardH[Index + Feature] = T;
                    BackWordH[Index + T] = Feature;
                    BackWordH[Index + Feature] = 0;
                }
                Histgram[Index + Feature]++;
            }
        }
        for (int X = 0; X < Width; X++)
        {
            int IndexF = LinePF[X] * LevelF;
            float SumW = 0, HalfSumW = 0;;
            for (int I = 0; I < LevelV; I++)
            {
                float Cum = 0;
                int Index = I * LevelF;
                int J = 0;
                do
                {
                    Cum += Histgram[Index + J] * Weight[IndexF + J];        //    跳过那些非0的元素
                    J = ForwardH[Index + J];
                } while (J != 0);
                Sum[I] = Cum;                            //    计算每个Value对应的全部Featrue的权重累计和
                SumW += Cum;
            }
            HalfSumW = SumW / 2;
            SumW = 0;
            for (int I = 0; I < LevelV; I++)
            {
                SumW += Sum[I];
                if (SumW >= HalfSumW)
                {
                    LinePD[X] = I;
                    break;
                }
            }
            if ((X - Radius) >= 0)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    int Value = Input[J * Stride + X - Radius];
                    int Feature = FeatureMap[J * Stride + X - Radius];
                    int Index = Value * LevelF;
                    Histgram[Index + Feature]--;
                    if (Histgram[Index + Feature] == 0 && Feature != 0)
                    {
                        int T1 = BackWordH[Index + Feature];
                        int T2 = ForwardH[Index + Feature];
                        ForwardH[Index + T1] = T2;
                        BackWordH[Index + T2] = T1;
                    }

                }
            }
            if ((X + Radius + 1) <= Width - 1)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    int Value = Input[J * Stride + X + Radius + 1];
                    int Feature = FeatureMap[J * Stride + X + Radius + 1];

                    int Index = Value * LevelF;
                    if (Histgram[Index + Feature] == 0 && Feature != 0)        // 直方图数据若是仍是0而且FMap值不为0
                    {
                        int T = ForwardH[Index];
                        ForwardH[Index] = Feature;
                        ForwardH[Index + Feature] = T;
                        BackWordH[Index + T] = Feature;
                        BackWordH[Index + Feature] = 0;
                    }
                    Histgram[Index + Feature]++;
                }
            }
        }
    }
FreeMemory:
    if (Histgram != NULL)        free(Histgram);
    if (ForwardH != NULL)        free(ForwardH);
    if (BackWordH != NULL)        free(BackWordH);
    if (Sum != NULL)            free(Sum);
    return Status;
}

      代码量不大,编译后测试,一样是21*21的窗口,one - metalpixel的灰度图像计算用1200ms左右,比Brute-force版本的27s大约快了22倍,因为这个算法和图像内容是由必定关系的,所以,和论文提供的数据直接比较的意义不大。

     4、最终的结合体

  很天然的,咱们想到要把Median Tracking 和 Necklace Table联合在一块儿,来进一步的提升速度,这个时候能够对Joint Histgram即BCB都使用 Necklace Table来记录非零元素,因而产生了如下的结合代码:

int IM_WeightedMedianBlur_05(unsigned char *Input, unsigned char *FeatureMap, float *Weight, unsigned char *Output, int Width, int Height, int Stride, int Radius)
{
    int Channel = Stride / Width;
    if ((Input == NULL) || (Output == NULL))                                        return IM_STATUS_NULLREFRENCE;
    if ((FeatureMap == NULL) || (Weight == NULL))                                    return IM_STATUS_NULLREFRENCE;
    if ((Width <= 0) || (Height <= 0) || (Radius <= 0))                                return IM_STATUS_INVALIDPARAMETER;
    if ((Channel != 1) && (Channel != 3) && (Channel != 4))                            return IM_STATUS_NOTSUPPORTED;
    int Status = IM_STATUS_OK;

    const int LevelV = 256;
    const int LevelF = 256;

    int *Histgram = (int *)malloc(LevelF * LevelV * sizeof(int));
    int *BCB = (int *)malloc(LevelF * sizeof(int));
    int *ForwardH = (int *)malloc(LevelF * LevelV * sizeof(int));            //    forward link for necklace table
    int *BackWordH = (int *)malloc(LevelF * LevelV * sizeof(int));            //    forward link for necklace table
    int *ForwardBCB = (int *)malloc(LevelF * sizeof(int));                    //    forward link for necklace table
    int *BackWordBCB = (int *)malloc(LevelF * sizeof(int));                    //    forward link for necklace table
    if ((Histgram == NULL) || (BCB == NULL) || (ForwardH == NULL) || (BackWordH == NULL) || (ForwardBCB == NULL) || (BackWordBCB == NULL))
    {
        Status = IM_STATUS_OK;
        goto FreeMemory;
    }

    memset(ForwardH, 0, LevelF * LevelV * sizeof(int));
    memset(BackWordH, 0, LevelF * LevelV * sizeof(int));
    memset(ForwardBCB, 0, LevelF * sizeof(int));
    memset(BackWordBCB, 0, LevelF * sizeof(int));

    for (int Y = 0; Y < Height; Y++)
    {
        unsigned char *LinePF = FeatureMap + Y * Stride;
        unsigned char *LinePD = Output + Y * Stride;
        memset(Histgram, 0, LevelF * LevelV * sizeof(int));                        //    所有赋值为0
        memset(BCB, 0, LevelF * sizeof(int));
        for (int X = 0; X < LevelV; X++)
        {
            ForwardH[X * LevelF] = 0;
            BackWordH[X * LevelF] = 0;
        }
        ForwardBCB[0] = 0;
        BackWordBCB[0] = 0;

        int CutPoint = -1;
        for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
        {
            int Index = J * Stride;
            for (int I = IM_Max(0 - Radius, 0); I <= IM_Min(0 + Radius, Width - 1); I++)
            {
                int Value = Input[Index + I];
                int Feature = FeatureMap[Index + I];
                int Index = Value * LevelF;
                if (Histgram[Index + Feature] == 0 && Feature != 0)        // 直方图数据若是仍是0而且FMap值不为0
                {
                    int T = ForwardH[Index];
                    ForwardH[Index] = Feature;
                    ForwardH[Index + Feature] = T;
                    BackWordH[Index + T] = Feature;
                    BackWordH[Index + Feature] = 0;
                }
                Histgram[Index + Feature]++;                //    计算每行第一个点的二维直方图,直方图的水平方向为Feature坐标,垂直方向为Value坐标        

                UpdateBCB(BCB[Feature], ForwardBCB, BackWordBCB, Feature, -1);        //    此时的CutPoint初始化为-1,因此+方向的数据为0,全部的都在-方向                                        
            }
        }

        for (int X = 0; X < Width; X++)
        {

            float BalanceWeight = 0;
            int IndexF = LinePF[X] * LevelF;                                    //    中心点P的Value所对应的那一行Feature权重起始索引
            int I = 0;
            do
            {
                BalanceWeight += BCB[I] * Weight[IndexF + I];                    //  按照当前BCB数据计算平衡值,BCB记录了相同的FMap值时按照以前的中间值左右两侧像素个数的差别值
                I = ForwardBCB[I];
            } while (I != 0);

            if (BalanceWeight < 0)                                                //    第一个点的BalanceWeight必然小于0
            {
                for (; BalanceWeight < 0 && CutPoint != LevelV - 1; CutPoint++)
                {
                    int IndexH = (CutPoint + 1) * LevelF;                        //    新的直方图的位置
                    float CurWeight = 0;
                    int I = 0;
                    do
                    {
                        CurWeight += 2 * Histgram[IndexH + I] * Weight[IndexF + I];        //    左侧加右侧同时减,因此是2倍
                        UpdateBCB(BCB[I], ForwardBCB, BackWordBCB, I, Histgram[IndexH + I] << 1);
                        I = ForwardH[IndexH + I];
                    } while (I != 0);
                    BalanceWeight += CurWeight;
                }
            }
            else if (BalanceWeight > 0)                                    //    若是平衡值大于0,则向左移动中间值
            {
                for (; BalanceWeight > 0 && CutPoint != 0; CutPoint--)
                {
                    int IndexH = CutPoint * LevelF;
                    float CurWeight = 0;
                    int I = 0;
                    do
                    {
                        CurWeight += 2 * Histgram[IndexH + I] * Weight[IndexF + I];        //    左侧加右侧同时减,因此是2倍
                        UpdateBCB(BCB[I], ForwardBCB, BackWordBCB, I, -(Histgram[IndexH + I] << 1));
                        I = ForwardH[IndexH + I];
                    } while (I != 0);
                    BalanceWeight -= CurWeight;
                }
            }
            LinePD[X] = CutPoint;

            if ((X - Radius) >= 0)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)        //    即将移出的那一列数据
                {
                    int Value = Input[J * Stride + X - Radius];
                    int Feature = FeatureMap[J * Stride + X - Radius];

                    int Index = Value * LevelF;
                    Histgram[Index + Feature]--;
                    if (Histgram[Index + Feature] == 0 && Feature != 0)
                    {
                        int T1 = BackWordH[Index + Feature];
                        int T2 = ForwardH[Index + Feature];
                        ForwardH[Index + T1] = T2;
                        BackWordH[Index + T2] = T1;
                    }
                    UpdateBCB(BCB[Feature], ForwardBCB, BackWordBCB, Feature, -((Value <= CutPoint) << 1) + 1);
                }
            }
            if ((X + Radius + 1) <= Width - 1)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    int Value = Input[J * Stride + X + Radius + 1];
                    int Feature = FeatureMap[J * Stride + X + Radius + 1];
                    int Index = Value * LevelF;
                    if (Histgram[Index + Feature] == 0 && Feature != 0)        // 直方图数据若是仍是0而且FMap值不为0
                    {
                        int T = ForwardH[Index];
                        ForwardH[Index] = Feature;
                        ForwardH[Index + Feature] = T;
                        BackWordH[Index + T] = Feature;
                        BackWordH[Index + Feature] = 0;
                    }
                    UpdateBCB(BCB[Feature], ForwardBCB, BackWordBCB, Feature, ((Value <= CutPoint) << 1) - 1);
                    Histgram[Index + Feature]++;

                }
            }
        }
    }
FreeMemory:
    if (Histgram != NULL)        free(Histgram);
    if (BCB != NULL)            free(BCB);
    if (ForwardH != NULL)        free(ForwardH);
    if (BackWordH != NULL)        free(BackWordH);
    if (ForwardBCB != NULL)        free(ForwardBCB);
    if (BackWordBCB != NULL)    free(BackWordBCB);
    return Status;
}

  咱们满怀期待的编译和执行他,结果出来了,一样是21*21的窗口,one - metalpixel的灰度图像计算用430ms左右,和Joint + MT的速度差很少,可是论文里给出的数据是Joint + MT + NT要比Joint + MT快3倍左右。这是怎么回事呢。

  咱们仔细检查论文里,在Implementation Notes节里有这样的语句:

              Only a single thread is used without involving any SIMD instructions. Our system is implemented using C++. 

  第一,他也是用的C++和我同样,第二,他是单线程,也和我同样,第三,没有使用任何SIMD指令,彷佛我也没有使用啊,都同样,为何结果比对不一致,难道是大神他们做弊,鉴于他们的成就,我当即撤回我这逆天的想法,必定是其余地方有问题。咱们试着反编译看看。

  咱们定位到Joint + MT的算法的下面一句代码看看:

    for (int I = 0; I < LevelF; I++)                                    //    BCB[I]中保存的是以CutPoint为分界线,Feature为I时,分界线左侧的全部Value[0-CutPoint]值的数量和分界线右侧全部的Value(CutPoint, LevelV - 1]值数量的差别
    {
         BalanceWeight += BCB[I] * Weight[IndexF + I];                    //    由于Feature为固定值时,若是中心点固定,那么无论与Feature对应的Value值时多少,Weight就是定值了。
    }

  反编译结果为:

    for (int I = 0; I < LevelF; I++)                                    //    BCB[I]中保存的是以CutPoint为分界线,Feature为I时,分界线左侧的全部Value[0-CutPoint]值的数量和分界线右侧全部的Value(CutPoint, LevelV - 1]值数量的差别
            {
                BalanceWeight += BCB[I] * Weight[IndexF + I];                    //    由于Feature为固定值时,若是中心点固定,那么无论与Feature对应的Value值时多少,Weight就是定值了。
0FAF1B25  movdqu      xmm0,xmmword ptr [ecx]  
0FAF1B29  add         ecx,10h  
0FAF1B2C  cvtdq2ps    xmm1,xmm0  
0FAF1B2F  movups      xmm0,xmmword ptr [eax]  
0FAF1B32  add         eax,10h  
0FAF1B35  mulps       xmm1,xmm0  
0FAF1B38  addps       xmm2,xmm1  
0FAF1B3B  dec         edx  
0FAF1B3C  jne         IM_WeightedMedianBlur_03+1B5h (0FAF1B25h)  
            }

  赤裸裸的SIMD指令啊。

  为何呢,只是由于VS的编译器即便在默认状况下的设置中,也会根据当前编译系统的状况,进行必定的向量化优化,加上如今的PC基本没有哪个不能使用SIMD指令的。以下图所示,为C++默认编译选项:

           

  在启用加强指令集选项里默认是未设置,可是未设置并不表明不使用,正如上述所言,测试编译器会根据系统情况优化编译。所以,虽然表面上代码没有使用SIMD指令,可是实际却使用了。

  为了公平起见,咱们禁用系统的SIMD优化,此时,能够在加强指令集的选项里选择“无加强指令/arch:IA32".

         

  编译后,对上述一样一段代码进行反编译,能够看到以下汇编码:

for (int I = 0; I < LevelF; I++)                                    //    BCB[I]中保存的是以CutPoint为分界线,Feature为I时,分界线左侧的全部Value[0-CutPoint]值的数量和分界线右侧全部的Value(CutPoint, LevelV - 1]值数量的差别
            {
                BalanceWeight += BCB[I] * Weight[IndexF + I];                    //    由于Feature为固定值时,若是中心点固定,那么无论与Feature对应的Value值时多少,Weight就是定值了。
0F8F1AF5  fild        dword ptr [ecx-4]  
0F8F1AF8  fmul        dword ptr [eax+4]  
0F8F1AFB  fild        dword ptr [ecx-8]  
0F8F1AFE  fmul        dword ptr [eax]  
0F8F1B00  faddp       st(2),st  
0F8F1B02  faddp       st(1),st  
0F8F1B04  fild        dword ptr [ecx]  
0F8F1B06  fmul        dword ptr [eax+8]  
0F8F1B09  faddp       st(1),st  
0F8F1B0B  fild        dword ptr [ecx+4]  
0F8F1B0E  fmul        dword ptr [eax+0Ch]  
0F8F1B11  faddp       st(1),st  
0F8F1B13  fild        dword ptr [ecx+8]  
0F8F1B16  fmul        dword ptr [eax+10h]  
0F8F1B19  faddp       st(1),st  
0F8F1B1B  fild        dword ptr [ecx+0Ch]  
0F8F1B1E  fmul        dword ptr [eax+14h]  
0F8F1B21  faddp       st(1),st  
0F8F1B23  fild        dword ptr [ecx+10h]  
0F8F1B26  fmul        dword ptr [eax+18h]  
0F8F1B29  faddp       st(1),st  
0F8F1B2B  fild        dword ptr [ecx+14h]  
0F8F1B2E  add         ecx,20h  
0F8F1B31  fmul        dword ptr [eax+1Ch]  
0F8F1B34  add         eax,20h  
0F8F1B37  faddp       st(1),st  
0F8F1B39  dec         edi  
0F8F1B3A  jne         IM_WeightedMedianBlur_03+1B5h (0F8F1AF5h)  
            }

  这里是明显的普通的FPU代码,多说一句,针对这个循环,系统也进行了多路并行优化。

    为了比较方便,咱们把禁用系统优化后的时间和未禁用是作一个总体的对比:

算法名称

执行时间

禁用编译器优化

启用编译器优化

BruteForce

26875ms

27025ms

Joint Histgram

123432ms

108254ms

Joint Hist CacheFriend

55214ms

17325ms

Joint + MT

1075ms

420ms

Joint + NT

1286ms

1200ms

Joint + MT + NT

422ms

430ms

 

      当禁用编译器优化后,能够明显的看到Joint + MT + NT的速度优点比较大,和论文里给出的数据也基本至关了。

      可是咱们仍是稍做分析,为何一样是开启编译器优化,Joint + MT的速度能从1075ms下降到420ms,而Joint + MT + NT确基本没有什么变化呢,这就要从代码自己提及。

      咱们注意到,在Joint + MT版本中,BalanceWeight和CurWeight等元素的计算都是经过一个简单的for循环进行的,计算过程当中循环的次数是固定的,每次计算内部的循环变量取值也是按照内存顺序来的,这种代码很是适合编译器使用SIMD指令优化,他会自动编译一系列带P(Packet)字母的SIMD指令(例如mulps)进行单周期四指令的快速执行,至关于提升了4倍的通行能力,而那些计算在整个算法里占用的时间比例有比较大,这样对整个算法的提速表现贡献是很大的。

      而在有了Necklace Table参与的版本中,因为BalanceWeight和CurWeight的更新使用do while循环,循环的次数是未知的,循环里的指针指向的位置也是变更的,所以,即便使用了SIMD指令,他也只能使用其中带S(Single)字母的SIMD指令(例如mulss),这种指令一次性也就是执行一条计算,相比普通的FPU指令提速很是有限甚至更慢,所以,优不优化速度基本没啥区别。另一个重要的问题在论文中其实没有说起,那就是随着半径的增长,Joint Histgram中得非0元素会相对的变得愈来愈少(但总体比例仍是很大的),可是在BCB中,只要某个固定Feature对应的LevelF个直方图元素中有一个不为0,那么他就会不为0,这个状况在大半径时发生的几率很是高,此时的更新Necklace Table的时间和后续减小计算的时间来讲可能会本末倒置,反而会引发计算时间的增长。

  基于这样一个分析,隐含着这样一个事实,当半径比较小时,因为计算过程当中非零值的存在,Joint + MT + NT应该效果会更改,而随着半径的增长,非零值减少,NT带来的收益愈来愈小,甚至抵消了,咱们实测了下面一组数据。

算法名称

不一样半径时的执行时间(ms)

1

3

5

8

10

15

20

40

Joint + MT

386

404

396

416

436

500

540

744

Joint + MT + NT

153

316

306

412

452

534

654

1091

 

      也就是说,在允许进行SIMD优化的状况下,当半径大于10时,建议使用Joint + MT来得到更高的效率,半径小于10时,可经过Joint + MT + NT来提供更好的速度。

      从代码的简练或者内存占用方面来讲,毫无疑问Joint + MT更简单,也更加节省内存,若是在如今的PC上使用该算法,我更喜欢直接使用Joint + MT算法

      这样并非说Necklace Table很差,我反到以为这个数据结构也是由很高的利用价值,也许能够利用到我关心的其余一些算法上,会有这比较好的效果。

  另外小声的说一下,彷佛这里的最终优化的时间和Brute force的时间比并无达到100:1。

      5、后续关于Joint + MT进一步优化的几个尝试

  既然选中Joint + MT,咱们再仔细的构思下他尚未进一步优化的余地呢,第一想到的就是,我自行内嵌SIMD指令,代码中有好几个for循环使用SIMD指令应该很容易处理,可是,通过屡次改写,发现这种很是简便的for循环,咱们本身内嵌的SIMD指令很难超越编译器编译后的速度,毕竟写编译器的那些专家的优化水平,不是我等可以比拟的。第一步方向选择放弃。

      那么若是考虑定点话呢,通常两个像素之间的权重值是个介于0和1之间的数据,若是咱们把它放大必定倍数,转换为整形,那么整个计算过程就是整形的处理,并且如今整形也能够直接使用SSE处理,一样是一次性处理4个32位整形,同浮点相比,少了几回数据类型的转换,通过测试,这样处理后速度基本没有什么大的差别,这个方法也能够放弃。

     第三个想法是直方图的更新,有一种经常使用的直方图更新方法是特例化处理图像总体最左上角的点,而后在水平方向移动时,去除最左侧的一列信息,加上最右侧的信息,当移动到第一行最右侧的像素点时,此时的更新方向不是直接跳到第二行首像素,而是从第二行尾像素向第二行手像素进行处理,这时咱们能够充分利用第一行的最右侧像素的直方图数据,只要减去最上部一行的直方图信息,而后加上最下部一行的直方图的信息就能够了,在逆向移动时,直方图的更新则和第一行的更新相反,加上左侧的信息,而后减去右侧信息,当处理到第二行首地址像素后,咱们又跳到第三行首地址,而后进行相似第一行的处理,这种处理方式可以减小对每行首像素进行所有直方图更新的计算量,在半径较大时有必定的加速做用,咱们通常称之为蛇形算法。实验了一下,对算法的速度提高很是有限,并且会使得代码稍显繁琐。也须要放弃。

     那么目前我想到的惟一的有可能对速度还有提高的就是定点化时不用32位的数据,适当的考虑数据的范围,若是能保证定点后的数据能在16位的有效范围,那么仍是有可能进一步提升点速度的,毕竟这个时候可使用SSE单指令一次性进行8个整数的加减乘法了,这个有待于进一步去测试。

  6、特例优化

  在有些状况下甚至不少状况下,咱们使用的Feature是其自身,这种状况下由于数据的特殊性,咱们能够作一些特殊处理,使得算法的速度更快。

  当Feature等于Input自己时,咱们注意到,联合直方图中只有45度的对角线中元素有值,其余部位都为0,所以,咱们能够考虑联合直方图在形式上退化为一维直方图,这个时候一个简单的代码以下所示:

int IM_WeightedMedianBlur_Special(unsigned char *Input, float *Weight, unsigned char *Output, int Width, int Height, int Stride, int Radius)
{
    int Channel = Stride / Width;
    if ((Input == NULL) || (Output == NULL))                                        return IM_STATUS_NULLREFRENCE;
    if ((Width <= 0) || (Height <= 0) || (Radius <= 0))                                return IM_STATUS_INVALIDPARAMETER;
    if ((Channel != 1) && (Channel != 3) && (Channel != 4))                            return IM_STATUS_NOTSUPPORTED;

    const int Level = 256;
    
    int *Histgram = (int *)malloc(Level * sizeof(int));
    if (Histgram == NULL)    return IM_STATUS_OUTOFMEMORY;
    for (int Y = 0; Y < Height; Y++)
    {
        unsigned char *LinePS = Input + Y * Stride;
        unsigned char *LinePD = Output + Y * Stride;
        memset(Histgram, 0, Level * sizeof(int));                        //    所有赋值为0
        for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
        {
            int Index = J * Stride;
            for (int I = IM_Max(0 - Radius, 0); I <= IM_Min(0 + Radius, Width - 1); I++)
            {
                Histgram[Input[Index + I]]++;
            }
        }
        for (int X = 0; X < Width; X++)
        {
            int IndexF = LinePS[X] * Level;
            float SumW = 0, HalfSumW = 0;;
            for (int I = 0; I < Level; I++)
            {
                SumW += Histgram[I] * Weight[IndexF + I];
            }

            HalfSumW = SumW / 2;
            SumW = 0;
            for (int I = 0; I < Level; I++)
            {
                SumW += Histgram[I] * Weight[IndexF + I];
                if (SumW >= HalfSumW)
                {
                    LinePD[X] = I;
                    break;
                }
            }
            if ((X - Radius) >= 0)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    Histgram[Input[J * Stride + X - Radius]]--;
                }
            }
            if ((X + Radius + 1) <= Width - 1)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    Histgram[Input[J * Stride + X + Radius + 1]]++;
                }
            }
        }
    }
    free(Histgram);
    return IM_STATUS_OK;
}

  一样是21*21的窗口,one - metalpixel的灰度图像计算用367ms左右,比上述都要快。

  一样的道理,咱们也可使用BCB技术来优化,可是此时的BCB来的更简单。

int IM_WeightedMedianBlur_Special_BCB(unsigned char *Input, float *Weight, unsigned char *Output, int Width, int Height, int Stride, int Radius)
{
    int Channel = Stride / Width;
    if ((Input == NULL) || (Output == NULL))                                        return IM_STATUS_NULLREFRENCE;
    if ((Width <= 0) || (Height <= 0) || (Radius <= 0))                                return IM_STATUS_INVALIDPARAMETER;
    if ((Channel != 1) && (Channel != 3))                                            return IM_STATUS_NOTSUPPORTED;
    int Status = IM_STATUS_OK;

    const int Level = 256;                

    int *Histgram = (int *)malloc(Level * sizeof(int));
    int *BCB = (int *)malloc(Level * sizeof(int));

    if ((Histgram == NULL) || (BCB == NULL))
    {
        Status = IM_STATUS_OK;
        goto FreeMemory;
    }

    for (int Y = 0; Y < Height; Y++)
    {
        unsigned char *LinePS = Input + Y * Stride;
        unsigned char *LinePD = Output + Y * Stride;
        memset(Histgram, 0, Level * sizeof(int));                        //    所有赋值为0
        memset(BCB, 0, Level * sizeof(int));
        int CutPoint = -1;
        for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
        {
            int Index = J * Stride;
            for (int I = IM_Max(0 - Radius, 0); I <= IM_Min(0 + Radius, Width - 1); I++)
            {
                int Value = Input[J * Stride + I];
                Histgram[Value]++;                        //    计算每行第一个点的二维直方图,直方图的水平方向为Feature坐标,垂直方向为Value坐标    
                BCB[Value]--;                            //    此时的CutPoint初始化为-1,因此+方向的数据为0,全部的都在-方向        
            }
        }

        for (int X = 0; X < Width; X++)
        {
            float BalanceWeight = 0;
            int IndexF = LinePS[X] * Level;                                    //    中心点P的Value所对应的那一行Feature权重起始索引
            for (int I = 0; I < Level; I++)                                    //    BCB[I]中保存的是以CutPoint为分界线,Feature为I时,分界线左侧的全部Value[0-CutPoint]值的数量和分界线右侧全部的Value(CutPoint, LevelV - 1]值数量的差别
            {
                BalanceWeight += BCB[I] * Weight[IndexF + I];                    //    由于Feature为固定值时,若是中心点固定,那么无论与Feature对应的Value值时多少,Weight就是定值了。
            }
            if (BalanceWeight < 0)                                                //    第一个点的BalanceWeight必然小于0
            {
                for (; BalanceWeight < 0 && CutPoint != Level - 1; CutPoint++)
                {
                    int Index = CutPoint + 1;                        //    新的直方图的位置
                    BCB[Index] += Histgram[Index] * 2;                        //    数量是一样的道理
                    BalanceWeight += 2 * Histgram[Index] * Weight[IndexF + Index];
                }
            }
            else if (BalanceWeight > 0)                                    //    若是平衡值大于0,则向左移动中间值
            {
                for (; BalanceWeight > 0 && CutPoint != 0; CutPoint--)
                {
                    BCB[CutPoint] -= Histgram[CutPoint] * 2;
                    BalanceWeight -= 2 * Histgram[CutPoint] * Weight[IndexF + CutPoint];;
                }
            }
            LinePD[X] = CutPoint;

            if ((X - Radius) >= 0)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)        //    即将移出的那一列数据
                {
                    int Value = Input[J * Stride + X - Radius];
                    Histgram[Value]--;
                    if (Value <= CutPoint)                        //    若是移出的那个值小于当前的中值
                        BCB[Value]--;
                    else
                        BCB[Value]++;
                }
            }
            if ((X + Radius + 1) <= Width - 1)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    int Value = Input[J * Stride + X + Radius + 1];
                    Histgram[Value]++;
                    if (Value <= CutPoint)                        //    若是移出的那个值小于当前的中值
                        BCB[Value]++;
                    else
                        BCB[Value]--;
                }
            }
        }
    }
FreeMemory:
    if (Histgram != NULL)    free(Histgram);
    if (BCB != NULL)        free(BCB);
    return Status;
}

  一样是21*21的窗口,one - metalpixel的灰度图像计算用242ms左右。

  若是咱们进一步退化,将其退化为普通的中值滤波,即全部Weight都相同,则删减不须要的相关代码后,能够有以下过程:

int IM_MedianBlur(unsigned char *Input, unsigned char *Output, int Width, int Height, int Stride, int Radius)
{
    int Channel = Stride / Width;
    if ((Input == NULL) || (Output == NULL))                                        return IM_STATUS_NULLREFRENCE;
    if ((Width <= 0) || (Height <= 0) || (Radius <= 0))                                return IM_STATUS_INVALIDPARAMETER;
    if ((Channel != 1) && (Channel != 3))                                            return IM_STATUS_NOTSUPPORTED;
    int Status = IM_STATUS_OK;

    const int Level = 256;

    int *Histgram = (int *)malloc(Level * sizeof(int));
    if ((Histgram == NULL))
    {
        Status = IM_STATUS_OK;
        goto FreeMemory;
    }
    for (int Y = 0; Y < Height; Y++)
    {
        unsigned char *LinePS = Input + Y * Stride;
        unsigned char *LinePD = Output + Y * Stride;
        memset(Histgram, 0, Level * sizeof(int));                        //    所有赋值为0
        int CutPoint = -1;
        int Balance = 0;

        for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
        {
            int Index = J * Stride;
            for (int I = IM_Max(0 - Radius, 0); I <= IM_Min(0 + Radius, Width - 1); I++)
            {
                int Value = Input[J * Stride + I];
                Histgram[Value]++;                        //    计算每行第一个点的二维直方图,直方图的水平方向为Feature坐标,垂直方向为Value坐标    
                Balance--;
            }
        }
        for (int X = 0; X < Width; X++)
        {    
            
            if (Balance < 0)                                                //    第一个点的Balance必然小于0
            {
                for (; Balance < 0 && CutPoint != Level - 1; CutPoint++)
                {            
                    Balance += 2 * Histgram[CutPoint + 1];
                }
            }
            else if (Balance > 0)                                    //    若是平衡值大于0,则向左移动中间值
            {
                for (; Balance > 0 && CutPoint != 0; CutPoint--)
                {
                    Balance -= 2 * Histgram[CutPoint];
                }
            }
            LinePD[X] = CutPoint;
            if ((X - Radius) >= 0)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)        //    即将移出的那一列数据
                {
                    int Value = Input[J * Stride + X - Radius];
                    Histgram[Value]--;
                    if (Value <= CutPoint)                        //    若是移出的那个值小于当前的中值
                        Balance--;
                    else
                        Balance++;
                }
            }
            if ((X + Radius + 1) <= Width - 1)
            {
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)
                {
                    int Value = Input[J * Stride + X + Radius + 1];
                    Histgram[Value]++;
                    if (Value <= CutPoint)                        //    若是移出的那个值小于当前的中值
                        Balance++;
                    else
                        Balance--;
                }
            }
        }
    }
FreeMemory:
    if (Histgram != NULL)    free(Histgram);
    return Status;
}

     一样是21*21的窗口,one - metalpixel的灰度图像计算用140ms左右。

     有兴趣的朋友还能够试下对上述中值模糊的代码在加上Necklace table优化,看看能获得什么样的结果。

     在论文的最后,讲述了加权中值模糊的多个应用场景,好比在光流、立体匹配、JPG瑕疵修复、艺术特效等等方面,我测试下几个我能作的测试,确实有不错的效果,好比下面的JPG瑕疵修复。对简单的图处理后确实蛮好的,若是在结合我以前研究的MLAA去锯齿算法,恢复后的图像质量就更高了,以下所示:

                           

             

                                             

            原图                                 加权中值模糊(特征图为原图)                  MLAA后续处理后(边缘更平滑)

        另外,WMF的保边特性感受比其余的如导向滤波、双边滤波等等都要强烈的多,好比下图:  

         

  花朵的边缘,下面的文字等等处理都还特别清晰,不像其余的保边滤波器总有点模糊,这个特性也许用到一些加强上也会有很不错的效果。

  按照上述文章的思路,我整理和编制一个简易的测试程序,用来论证论文和我博文中得一些数据,使用的VS2013编译的,用C++作的DLL,C#作的UI测试界面,不依赖于任何其余第三方库,目前只作了灰度图的方案,由于彩色的话也基本就是三个通道独立写,能够经过拆分而后调用灰度的来实现。我也测试了下做者分享的VS工程,应该比我提供的代码速度稍微慢一点。

  

  源代码下载地址:https://files.cnblogs.com/files/Imageshop/WeightedMedianBlur.rar

  后记:

  写完文章后,对于Joint + MT算法总以为应该还有能够继续改进的地方,这几日也还在琢磨这事,有如下几个收获能够进一步提升速度。

  第一:正如前文所描述的是否能够考虑直方图数据用16位来表示呢,包括BCB都用16位。咱们来简单分析下。

  咱们看到Joint Histgram中一共有LevelV * LevelF个元素,局部窗口内有n=(2r+1)*(2r+1)个元素,那么在最极端的状况下这n个元素值都相同,且其对应的n个feature值也相同,这样在histgram中元素的最大值就是n,只要这个n小于short能表示的最大的正数,则用short就能够彻底表达完整的直方图信息,此时对应的r值约为90,彻底能知足实际的需求了,并且这种极端状况基本不会发生。

  一样对于BCB,也不太可能在一个局部出现其值超出short能表示的正负范围的。

  那么对于权重值,咱们也能够把他们定点化,通常权重都会在[0,1]范围内的一个数,即便不是,咱们也能够把他们归一化,而后好比放大16384倍,使用一个short类型数据来保存。

  这样作的好处就是,咱们可使用simd中关于16位的一些高级计算指令了,好比下面这段代码:

    int BalanceWeight = 0; for (int I = 0; I < LevelF; I++) { BalanceWeight += BCB[I] * W[IndexF + I]; }

  则能够优化为:

    __m128i BW1 = _mm_setzero_si128(); __m128i BW2 = _mm_setzero_si128(); for (int I = 0; I < Block * BlockSize; I += BlockSize) { BW1 = _mm_add_epi32(BW1, _mm_madd_epi16(_mm_load_si128((__m128i *)(BCB + I)), _mm_load_si128((__m128i *)(W + IndexF + I)))); BW2 = _mm_add_epi32(BW2, _mm_madd_epi16(_mm_load_si128((__m128i *)(BCB + I + 8)), _mm_load_si128((__m128i *)(W + IndexF + I + 8)))); } int BalanceWeight = _mm_hsum_epi32(_mm_add_epi32(BW1, BW2));

  其中int BlockSize = 16, Block = LevelF / BlockSize;

  _mm_madd_epi16能够一次性的进行8个16位数据的乘法和加法计算,效率及其高效。

  后面的BalanceWeight 中得校订代码的for循环也可使用相似方法优化。

  这样作还有个好处就是占用的内存小了,并且Y循环里的memset工做量也会少一半。

  第2、咱们在更新BCB的时候一段这样的小代码:

if (Value <= CutPoint)                    
    BCB[Feature]--;
else
    BCB[Feature]++;

  别看很短小,因为他出如今直方图的更新里,所以执行的频率很高。咱们看下他的反汇编:

if (Value <= CutPoint)                    
0F271E3D  mov         edi,dword ptr [esp+28h]  
0F271E41  cmp         ecx,dword ptr [esp+0Ch]  
0F271E45  jg          IM_WeightedMedianBlur_Joint_MT+495h (0F271E55h)  
    BCB[Feature]--;
0F271E47  mov         ecx,dword ptr [esp+38h]  
0F271E4B  dec         word ptr [edi+edx*2]  
                    Index += Stride;
0F271E4F  add         esi,dword ptr [Stride]  
0F271E52  inc         ecx  
0F271E53  jmp         IM_WeightedMedianBlur_Joint_MT+44Dh (0F271E0Dh)  
                for (int J = IM_Max(Y - Radius, 0); J <= IM_Min(Y + Radius, Height - 1); J++)        //    即将移出的那一列数据
0F271E55  mov         ecx,dword ptr [esp+38h]  
else
    BCB[Feature]++;
0F271E59  inc         word ptr [edi+edx*2]  
                    Index += Stride;
0F271E5D  add         esi,dword ptr [Stride]  
0F271E60  inc         ecx  
0F271E61  jmp         IM_WeightedMedianBlur_Joint_MT+44Dh (0F271E0Dh)  
                    Index += Stride;

  很明显,里面有jmp跳转指令,之前我不以为这个有什么速度影响,可是咱们尝试着用一些其余代码技巧替代这段代码后,速度却有了质的提高。

BCB[Value] += -((Value <= CutPoint) << 1) + 1;

  反汇编看下:

BCB[Value] += -((Value <= CutPoint) << 1) + 1;
0F93126B  mov         eax,1  
0F931270  mov         ecx,dword ptr [ebp-20h]  
0F931273  dec         word ptr [ecx+edx*2]  
0F931277  xor         ecx,ecx  
0F931279  cmp         edx,esi  
0F93127B  setle       cl  
0F93127E  add         cx,cx  
0F931281  sub         ax,cx  
0F931284  mov         ecx,dword ptr [ebp-40h]  
0F931287  add         word ptr [edi+edx*2],ax  
0F93128B  mov         eax,dword ptr [ebp-14h]  
0F93128E  inc         eax  
0F93128F  mov         dword ptr [ebp-14h],eax  

  里面没有了jmp跳转了。

  第三:程序里的IM_Max有点多,能够提取到X的循环外面。

  第四个尝试是,咱们在更新直方图时是按列更新的,这种状况的Cache Miss至关严重,一种改进的方式是,咱们备份一个原图和特征图的转置图,这个时候更新直方图时就是按照行方向读取数据了,此时会多一个转置的操做,可是转置已经可使用SSE代码进行高度的优化,在这个算法里这个的耗时几乎能够忽略不计。实测在半径小于10时,对总体速度无啥影响,可是随着半径增大,这个的效果愈来愈明显了。

  通过上述几个步骤的优化和处理,一样是21*21的窗口,one - metalpixel的灰度图像计算用时205ms左右,若是是彩色图像耗时大概在630ms左右,这个比做者提供的代码的执行速度快了大概3倍。

  在Input和Feature相同的状况下,也能够作一样的优化,此时,一样是21*21的窗口,one - metalpixel的灰度图像计算用时125ms左右,若是是彩色图像耗时大概在340ms左右。

  一个示例Demo可从:SSE_Optimization_Demo.rar处下载。

  

  若是以为本文对你有帮助,还请点个赞或者给我来杯小Coffee吧。

  

相关文章
相关标签/搜索