About Tech. Prog. Muti-Core ARM Proc Coprocessors GPUs HPC Cluster App. Kernels Registration

Mode-1 Multi-Core Memory Allocators OpenMP Intel TBB Pthreads Java - Threads Charm++ Prog. Message Passing (MPI) MPI - OpenMP MPI - Intel TBB MPI - Pthreads Compiler Opt. Features Threads-Perf. Math.Lib. Threads-Prof. & Tools Threads-I/O Perf. PGAS : UPC / CAF / GA Power-Perf. Home





hyPACK-2013 : Prog. on Multi-Core Processors Using Java - concurrent API


Multi-threading changed drastically in JDK 5.0, with the addition of a large number of classes and interfaces that provide high-quality implementations of the mechanisms that most application programmers will need.
Java-1.5 included following three new packages/sub-packages for concurrent programming.

1. java.util.concurrent
2. java.util.concurrent.atomic
3. java.util.concurrent.locks

Example programs using Java Concurrent APIs. Compilation and execution of Java threads programs, programs numerical and non-numerical computations are discussed using Java Concurrent APIs and understand Performance issues on multi-core processors.


Example 2.1

Write a Java concurrent APIs program for sorting an unsorted array using Bubble Sorting Algorithm

Example 2.2

Write a Java concurrent APIs program for Rank calculation for a large Array

Example 2.3

Write a Java concurrent APIs program for calculate power of n

Example 2.4

Write a Java concurrent APIs for calculate Fibonacci series

Example 2.5


Write a Java concurrent APIs for concurrently read and write a memory block using new "Read-write lock" (New Concurrency Java APIs) than old "synchronization" construct.

Example 2.6


Write a Java concurrent APIs program for concurrently read and write to a concurrentHashMap collection(New Concurrency Java APIs) and compare performance with old Hashtable collection.

Example 2.7

Write a Java concurrent APIs program for concurrently read and write to a Vector and ArrayList collection and check the performance improvement

Example 2.8


Write a Java concurrent APIs program for CopyOnwriteArrayList collection which is thread safe version of old ArrayList collection,allows concurrent updation on ArrayList while iterating

Description of Java Concurrent APIs Programs

Example 2.1: Java concurrent APIs program for sorting an unsorted array of natural numbers using Buble Sorting Algorithm
(Download source code : BubbleSortTest.java (WINRAR ZIP Archive) )

  • Objective

    • Write a Java concurrent APIs program for sorting an unsorted array using Bubble Sorting Algorithm

  • Description

    • Program for sorting an unsorted array using Bubble Sorting Algorithm takes array length and number of thread as argument and calculates execution time for serial/parallel/Executor API of bubble sort algorithm implementation.

  • Input

    • Array Length

    Number of Thread

  • Output

    • Sorted Array with execution time for serial/parallel/Executor API

Example 2.2: Java concurrent APIs program for Rank calculation for a given array
(Download source code : RankCalculation.java (WINRAR ZIP Archive) )

  • Objective

    • Write a Java concurrent APIs program for Rank calculation for a large Array

  • Description

    • The rank of the element in the array is the number of smaller elements in the array plus number of equal elements that appear to its left. It takes array length and number of thread as argument and calculates execution time for serial/parallel/Executor API of Rank calculation.

  • Input

    • Array Length

    Number of Thread

  • Output

    • Rank of each array element with execution time for serial/parallel/Executor API

Example 2.3: Java concurrent APIs program for calculate power of n.
(Download source code : PowerOfN.java (WINRAR ZIP Archive) )

      
  • Objective
    • Write a Java concurrent APIs program for calculate power of n

  • Description

    • Program for calculates power of n takes power value and number of threads as argument and calculates execution time for serial/parallel/Executor API power calculation of 1.0 with execution time for serial/parallel/Executor API

  • Input

    • Number of thread

  • Output

    • power calculation of 1.0 with execution time for serial/parallel/Executor API


Example 2.4: Java concurrent APIs program for calculating Fibonacci series.
(Download source code : Fibonacci.java (WINRAR ZIP Archive) )

  • Objective

    • Write a java concurrent APIs for calculate Fibonacci series

  • Description

    • Program for calculates Fibonacci number takes number that we want to calculate Fibonacci number as argument and calculates execution time serial/parallel/ Executor API Fibonacci number calculation.

  • Input

    • Number that we want to calculate Fibonacci number

  • Output

    • Fibonacci number with execution time for serial/parallel/Executor API

Example 2.5: Java concurrent APIs for concurrently read and write a memory block using new "Read-write lock" (New Concurrency Java APIs) than old "synchronization" construct.
(Download source code : RWLockExecutor.java (WINRAR ZIP Archive) )

  • Objective

    • Write a Java concurrent APIs for concurrently read and write a memory block using new "Read-write lock" (New Concurrency Java APIs) than old "synchronization" construct.

  • Description

    • Program for concurrently 100,00,00,000 read operation, 100,00,00,000 write operation on memory block using new "Read-write lock" (New Concurrency Java APIs) than old "synchronization" construct takes number of thread as argument and calculates execution time for Read-write lock / Synchronized /Read-Write Lock with Executor API implementation for 2/4/8/16/32/64/128/254 threads

  • Input

    • Number of thread

  • Output

    • Execution time for Read-write lock / Synchronized /Read-Write Lock with Executor API

Example 2.6: Java concurrent APIs for concurrently read and write to a concurrentHashMap collection(New Concurrency Java APIs) and compare performance with old Hashtable collection.
(Download source code : HashMapConcurrent.java (WINRAR ZIP Archive) )

  • Objective

    • Write a java concurrent APIs program for concurrently read and write to a concurrentHashMap collection(New Concurrency Java APIs) and compare performance with old Hashtable collection.

  • Description

    • Program for concurrently 100,00,00,000 read operation, 100,00,00,000 write operation on concurrentHashMap collection (New Concurrency Java APIs) and old Hashtable collection, which takes number of thread as argument and calculates execution time for serial/parallel/ Executor API implementation for 2/4/8/16/32/64/128/254 threads

  • Input

    • Number of thread

  • Output

    • Execution time for Hashtable/ConcurrentHashMap/HashMap

Example 2.7: Java concurrent APIs for concurrently read and writeto a Vector and ArrayList collection and check the performance improvement.
(Download source code : ListVectorConcurrent.java (WINRAR ZIP Archive) )

  • Objective

    • Write a Java concurrent APIs program for concurrently read and write to a Vector and ArrayList collection and check the performance improvement

  • Description

    • Program for concurrently 5,00,00,000 read operation, 1,00,000 write operation on ArrayList collection and old Vector collection, which takes number of thread as argument and calculates execution time for Vector/ArrayList for 2/4/8/16/32/64/128/254 threads

  • Input

    • Number of thread

  • Output

    • Execution time for Vector/ArrayList

Example 2.8: Write a Java concurrent APIs program for CopyOnwriteArrayList collection which is thread safe version of old ArrayList collection,allows concurrent updation on ArrayList while iterating
(Download source code : ListVectorCopyConcurrent.java (WINRAR ZIP Archive) )
  • Objective

    • Write a Java concurrent APIs program for CopyOnwriteArrayList collection which is thread safe version of old ArrayList collection,allows concurrent updation on ArrayList while iterating

  • Description

    • Program for concurrently 5,00,00,000 read operation-using iterator, 1,00,000 write operation on ArrayList Vector and CopyOnWriteArrayList (New Concurrency Java APIs) collection, which takes number of thread as argument and calculates execution time for Vector/ArrayList/ CopyOnWriteArrayList for 2/4/8/16/32/64/128/254 threads. CopyOnwriteArrayList collection, which is thread safe version of old ArrayList collection, allows concurrent updation on ArrayList while iterating. But ArrayList and Vector collection throws ConcurrentModificationException exception.

  • Input

    • Number of thread

  • Output

    • Execution time for Vector/ArrayList/CopyOnWriteArrayList

Centre for Development of Advanced Computing