OpenMP中的任务调度

OpenMP中，任务调度主要用于并行的for循环中，当循环中每次迭代的计算量不相等时，如果简单地给各个线程分配相同次数的迭代的话，会造成各个线程计算负载不均衡，这会使得有些线程先执行完，有些后执行完，造成某些CPU核空闲，影响程序性能。例如以下代码：

成都创新互联是专业的兰考网站建设公司，兰考接单;提供做网站、网站设计,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行兰考网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!

 
 
 
      
  
  
  1. int i, j; 
    2.   
  
  
  2. int a[100][100] = {0}; 
    3.   
  
  
  3. for ( i =0; i < 100; i++) 
    4.   
  
  
  4. { 
    5.   
  
  
  5. for( j = i; j < 100; j++ ) 
    6.   
  
  
  6. { 
    7.   
  
  
  7.     a[i][j] = i*j; 
    8.   
  
  
  8. } 
    9.   
  
  
  9. } 
    10.

如果将最外层循环并行化的话，比如使用4个线程，如果给每个线程平均分配25次循环迭代计算的话，显然i＝0和i＝99的计算量相差了100倍，那么各个线程间可能出现较大的负载不平衡情况。为了解决这些问题，OpenMP中提供了几种对for循环并行化的任务调度方案。

在OpenMP中，对for循环并行化的任务调度使用schedule子句来实现，下面介绍schedule字句的用法。

​1.1.1Schedule子句用法

schedule子句的使用格式为：

 
 
 
      
  
  
  1. schedule(type[,size]) 
    2.

schedule有两个参数：type和size，size参数是可选的。

1.  type参数

表示调度类型，有四种调度类型如下：

  • dynamic
  •  guided
  • runtime
  • static

这四种调度类型实际上只有static、dynamic、guided三种调度方式，runtime实际上是根据环境变量来选择前三种中的某中类型。

run-sched-var

2. size参数 (可选)

size参数表示循环迭代次数，size参数必须是整数。static、dynamic、guided三种调度方式都可以使用size参数，也可以不使用size参数。当type参数类型为runtime时，size参数是非法的（不需要使用，如果使用的话编译器会报错）。

1.1.2静态调度(static)

当parallel for编译指导语句没有带schedule子句时，大部分系统中默认采用static调度方式，这种调度方式非常简单。假设有n次循环迭代，t个线程，那 么给每个线程静态分配大约n/t次迭代计算。这里为什么说大约分配n/t次呢？因为n/t不一定是整数，因此实际分配的迭代次数可能存在差1的情况，如果 指定了size参数的话，那么可能相差一个size。

静态调度时可以不使用size参数，也可以使用size参数。

3.不使用size参数

不使用size参数时，分配给每个线程的是n/t次连续的迭代，不使用size参数的用法如下：

schedule(static)

例如以下代码：

 
 
 
      
  
  
  1. #pragma omp parallel for schedule(static) 
    2.   
  
  
  2.     for(i = 0; i < 10; i++ ) 
    3.   
  
  
  3.     { 
    4.   
  
  
  4.          printf("i=%d, thread_id=%d/n", i, omp_get_thread_num()); 
    5.   
  
  
  5. } 
    6.

上面代码执行时打印的结果如下：

i=0, thread_id=0

i=1, thread_id=0

i=2, thread_id=0

i=3, thread_id=0

i=4, thread_id=0

i=5, thread_id=1

i=6, thread_id=1

i=7, thread_id=1

i=8, thread_id=1

i=9, thread_id=1

可以看出线程0得到了0～4次连续迭代，线程1得到5～9次连续迭代。注意由于多线程执行时序的随机性，每次执行时打印的结果顺序可能存在差别，后面的例子也一样。

4. 使用size参数

使用size参数时，分配给每个线程的size次连续的迭代计算，用法如下：

 
 
 
      
  
  
  1. schedule(static, size) 
    2.

例如以下代码：

 
 
 
      
  
  
  1. #pragma omp parallel for schedule(static, 2) 
    2.   
  
  
  2.     for(i = 0; i < 10; i++ ) 
    3.   
  
  
  3.     { 
    4.   
  
  
  4.          printf("i=%d, thread_id=%d/n", i, omp_get_thread_num()); 
    5.   
  
  
  5. } 
    6.

执行时会打印以下结果：

i=0, thread_id=0

i=1, thread_id=0

i=4, thread_id=0

i=5, thread_id=0

i=8, thread_id=0

i=9, thread_id=0

i=2, thread_id=1

i=3, thread_id=1

i=6, thread_id=1

i=7, thread_id=1

从打印结果可以看出，0、1次迭代分配给线程0，2、3次迭代分配给线程1，4、5次迭代分配给线程0，6、7次迭代分配给线程1，…。每个线程依次分配到2次连续的迭代计算。

#p#

1.1.3动态调度(dynamic)

动态调度是动态地将迭代分配到各个线程，动态调度可以使用size参数也可以不使用size参数，不使用size参数时是将迭代逐个地分配到各个线程，使用size参数时，每次分配给线程的迭代次数为指定的size次。

下面为使用动态调度不带size参数的例子：

 
 
 
      
  
  
  1. #pragma omp parallel for schedule(dynamic) 
    2.   
  
  
  2.          for(i = 0; i < 10; i++ ) 
    3.   
  
  
  3.          { 
    4.   
  
  
  4.                   printf("i=%d, thread_id=%d/n", i, omp_get_thread_num()); 
    5.   
  
  
  5.          } 
    6.

打印结果如下：

i=0, thread_id=0

i=1, thread_id=1

i=2, thread_id=0

i=3, thread_id=1

i=5, thread_id=1

i=6, thread_id=1

i=7, thread_id=1

i=8, thread_id=1

i=4, thread_id=0

i=9, thread_id=1

下面为动态调度使用size参数的例子：

 
 
 
      
  
  
  1. #pragma omp parallel for schedule(dynamic, 2) 
    2.   
  
  
  2.          for(i = 0; i < 10; i++ ) 
    3.   
  
  
  3.          { 
    4.   
  
  
  4.                   printf("i=%d, thread_id=%d/n", i, omp_get_thread_num()); 
    5.   
  
  
  5.          } 
    6.

打印结果如下：

i=0, thread_id=0

i=1, thread_id=0

i=4, thread_id=0

i=2, thread_id=1

i=5, thread_id=0

i=3, thread_id=1

i=6, thread_id=0

i=8, thread_id=1

i=7, thread_id=0

i=9, thread_id=1

从打印结果可以看出第0、1，4、5，6、7次迭代被分配给了线程0，第2、3，8、9次迭代则分配给了线程1，每次分配的迭代次数为2。

1.1.4guided调度（guided）

guided调度是一种采用指导性的启发式自调度方法。开始时每个线程会分配到较大的迭代块，之后分配到的迭代块会逐渐递减。迭代块的大小会按指数级下降到指定的size大小，如果没有指定size参数，那么迭代块大小最小会降到1。

例如以下代码：

 
 
 
      
  
  
  1. #pragma omp parallel for schedule(guided,2) 
    2.   
  
  
  2.     for(i = 0; i < 10; i++ ) 
    3.   
  
  
  3.     { 
    4.   
  
  
  4.          printf("i=%d, thread_id=%d/n", i, omp_get_thread_num()); 
    5.   
  
  
  5. } 
    6.

打印结果如下：

i=0, thread_id=0

i=1, thread_id=0

i=2, thread_id=0

i=3, thread_id=0

i=4, thread_id=0

i=8, thread_id=0

i=9, thread_id=0

i=5, thread_id=1

i=6, thread_id=1

i=7, thread_id=1

第0、1、2、3、4次迭代被分配给线程0，第5、6、7次迭代被分配给线程1，第8、9次迭代被分配给线程0，分配的迭代次数呈递减趋势，最后一次递减到2次。

1.1.5runtime调度（rumtime）

runtime调度并不是和前面三种调度方式似的真实调度方式，它是在运行时根据环境变量OMP_SCHEDULE来确定调度类型，最终使用的调度类型仍然是上述三种调度方式中的某种。

例如在unix系统中，可以使用setenv命令来设置OMP_SCHEDULE环境变量：

setenv OMP_SCHEDULE “dynamic, 2”

上述命令设置调度类型为动态调度，动态调度的迭代次数为2。

在windows环境中，可以在”系统属性|高级|环境变量”对话框中进行设置环境变量。

本文标题：OpenMP中的任务调度
链接地址：http://www.mswzjz.cn/qtweb/news7/555657.html

攀枝花网站建设、攀枝花网站运维推广公司-贝锐智能，是专注品牌与效果的网络营销公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 贝锐智能

贝锐智能技术为您推荐以下文章

定制开发知识

行业网站建设

网站推广　　 　成都云主机　　 　光华服务器托管　　 　绵阳服务器托管　　 　都江堰网站建设　　 　营销网站建设　　 　重庆外贸网站建设　　 　成都圣月制冷　　 　免备案虚拟主机空间　　 　成都外贸网站优化　　 　微信开发　　 　成都定制网站建设　　 　成都广告招牌　　 　南充护栏钻孔机　　 　成都网站制作　　 　东电技服　　 　格蓝特设备　　 　成都网站维护　　 　手机网站制作　　 　西部信息服务器托管