JAVA CONCURRENT CYLICBARRIER

Yazan:Fatih KABAKCI

CylicBarrier, belirli sayıdaki thread' lerin tümünün çalışması bitene kadar, bu thread'leri , cyclic barrier olarak adlandırılan bir noktada, bekleten eş zamanlı nesnelerdir. İşini bitiren her thread, await() metodunu çağırarak, aynı bariyere ait diğer thread' leri beklemeye başlar. Toplamdaki tüm thread' lerin beklemesi, program kilidini bariyer noktasında açması anlamına gelir.

CyclicBarrier sınıfının, beklenecek thread sayısı ve bariyer noktasında çalıştırılacak Runnable sınıflarını belirten kurucu metotları aşağıda verilmektedir.

public CyclicBarrier(int paramInt)
public CyclicBarrier(int paramInt, Runnable paramRunnable)

CylicBarrier nesnesini, bir grup arkadaştan birisinin; ' herkes işini bitirdikten sonra şu köşede buluşalım ! ' demesi gibi düşünebilirsiniz. Gerçekten de işini bitiren her thread await() ile buluşmanın ayarlandığı noktada diğerlerini beklemektedir. Konuyu bir örnek ile anlamaya çalışalım.

Aşağıda 4 farklı bölgede(Güney, Kuzey, Doğu, Batı) yapılacak anket süreci verilmektedir.

Pollster Sınıfı

package Concurrent.CyclicBarrier;

import java.util.Random;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

/**
 * @author www.fatihkabakci.com
 */
public class Pollster implements Runnable {

   CyclicBarrier area;
   String        name;

   public Pollster(CyclicBarrier area, String name) {
      this.area = area;
      this.name = name;
      new Thread(this).start();
   }

   @Override
   public void run() {
      System.out.println("The survey results of " + name);
      double result = Math.abs(new Random().nextGaussian());
      try {
         area.await();
         System.out.println("Announced " + result + "% by " + name);
      }      
      catch (InterruptedException e) {
         e.printStackTrace();
      }
      catch (BrokenBarrierException e) {
         e.printStackTrace();
      }
   }
}

Announcement Sınıfı

package Concurrent.CyclicBarrier;

/**
 * @author www.fatihkabakci.com
 */
public class Announcement implements Runnable {

   @Override
   public void run() {
      System.out.println("The results of survey were announced !");
   }
}

Survey - Main Sınıfı

package Concurrent.CyclicBarrier;

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

/**
 * @author www.fatihkabakci.com
 * This class shows that how CyclicBarrier is implemented
 */
public class Survey {
   
   public static void main(String[] args) throws InterruptedException, BrokenBarrierException {
      CyclicBarrier area = new CyclicBarrier(4, new Announcement());

      new Pollster(area, "South");
      new Pollster(area, "West");
      new Pollster(area, "East");
      new Pollster(area, "North");
   }
}

Yukarıda program şu mantıkla çalışır:

Bölgelere göre 4 adet anketör oluşturulmuş olup, her bir bölgeye aynı bariyer nesnesi atanmıştır. Bölge anketörleri sonuçları hesapladıktan sonra await() ile diğer anketörleri bariyer noktasında bekler. Tüm anketörler işini bitirdikten sonra, Announcement thread' i bir kez çalışır ve akabinde tüm bölge anketörleri buluşma noktasında sonuçları ilan eder.

CyclicBarrier nesneleri bir grup thread' in çalışmasını belirli bir bariyer noktasında bekleterek program senkronizasyonunu sağlar. CountDownLatch Sınıfı ile benzetilebilir ama çalışma algoritması farklıdır. CountDownLatch Sınıfı bir sayma sayacı ile belirtilen olay sayısı arasında bağlantı kurar ve program çalışmasını bekleme noktasından devam ettirir. CyclicBarrier ise bir grup thread' in tümünün çalışmasının bitmesini bekler ve program çalışmasını yine thread' lerin belirlediği bir bekleme noktasından devam ettirir.