Java基于fork/koin類實(shí)現(xiàn)并發(fā)排序的示例

這篇文章將為大家詳細(xì)講解有關(guān)Java基于fork/koin類實(shí)現(xiàn)并發(fā)排序的示例，小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

概述

主要談一談 Java使用fork/koin類 實(shí)現(xiàn)的并發(fā)排序 以及對(duì)于Stream流的支持的splitetor

• mismatch() -> 尋找兩個(gè)數(shù)組 第一次出現(xiàn)數(shù)據(jù)不一致的下標(biāo)

• parallelPrefix() -> 對(duì)數(shù)組進(jìn)行,累加求和

• parallelSetAll() -> 對(duì)數(shù)組進(jìn)行置數(shù),

• parallelSort() -> 并行排序

• Spliterator() -> 對(duì)數(shù)組進(jìn)行切分(切分后的數(shù)據(jù)為所有的數(shù)據(jù)的組合)

奇數(shù) x/2+1 11->6

偶數(shù) x/2 10 ==>5

public class Use_Arrays {
   
  @Test
  public void test_mismatch() {
    int []x =new int[] {1,2,3,4};
    int []y =new int[] {1,3,4,5};
    int index = Arrays.mismatch(x, y);
    System.out.println(index);
  }
  
  @Test
  public void test_parallelPrefix() {
    int []x =new int[] {1,2,3,4};
    //f2=f1+f2
    //f3=f2+f3
    Arrays.parallelPrefix(x, (k,v)->k+v);
    System.out.println(Arrays.toString(x));
    
    // 實(shí)現(xiàn)1-100累加求和
    int []y =new int[100];
    Arrays.parallelSetAll(y, k->k=1);
    Arrays.parallelPrefix(y, (k,v)->k+v);
    System.out.println(Arrays.toString(y));
    
  }
  @Test
  public void test_parallelSetAll() {
    int []x =new int[100];
    x[0]=1;
    Arrays.parallelSetAll(x, y->y+1);
    System.out.println(Arrays.toString(x));
  }
  
  @Test
  public void test_parallSort() {
     IntStream stream = new Random().ints(0, 1000).limit(1000);
     int[] array = stream.toArray();
     System.out.println(Arrays.toString(array));
     Arrays.parallelSort(array);
     System.out.println(Arrays.toString(array));
  }
  
  @Test
  public void test_spliterator() {
    int []x =new int[11];
    Arrays.parallelSetAll(x, k->k+=1);
    System.out.println(Arrays.toString(x));
    
    Spliterator.OfInt int0_100 = Arrays.spliterator(x);
    
    int [] y=new int[(int) int0_100.estimateSize()];
    int i=0;
    System.out.println(int0_100.estimateSize());
    System.out.println(int0_100.characteristics());
    System.out.println(int0_100.getExactSizeIfKnown());
    
    //spliterator.forEachRemaining((int k)->System.out.println(k));
    
    OfInt int1_50 = int0_100.trySplit();
    OfInt int2_25 = int1_50.trySplit();
    int0_100.forEachRemaining((int k)->System.out.print(k+" "));
    System.out.println();
    int1_50.forEachRemaining((int k)->System.out.print(k+" "));
    System.out.println();
    int2_25.forEachRemaining((int k)->System.out.print(k+" "));
  }
}

2:使用Spliterator實(shí)現(xiàn)并行輸出

@Test
  public void definied_Sort() {
     IntStream stream = new Random().ints(0, 100).limit(100);
     int[] array = stream.toArray();
     Arrays.sort(array);
     final int NUMS=3;// 切分的次數(shù)
     
     ExecutorService thread_pool = Executors.newFixedThreadPool(10);
     
     Spliterator.OfInt cut1 = Arrays.spliterator(array);
     while(!thread_pool.isTerminated()) {
       thread_pool.submit(()->{
          OfInt split = cut1.trySplit();
           thread_pool.shutdown();
         split.forEachRemaining((int k)->System.out.print(k+" "));
         System.out.println();
       });
     }
  }

java基本數(shù)據(jù)類型有哪些

Java的基本數(shù)據(jù)類型分為：1、整數(shù)類型，用來(lái)表示整數(shù)的數(shù)據(jù)類型。2、浮點(diǎn)類型，用來(lái)表示小數(shù)的數(shù)據(jù)類型。3、字符類型，字符類型的關(guān)鍵字是“char”。4、布爾類型，是表示邏輯值的基本數(shù)據(jù)類型。

關(guān)于“Java基于fork/koin類實(shí)現(xiàn)并發(fā)排序的示例”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。