ゞ沉默是金ゞ

鱼离不开水,但是没有说不离开哪滴水.
posts - 98,comments - 104,trackbacks - 0
Part 9: java.util.concurrent : FixedThreadPool Example
This article will discuss about Thread pool with fixed number of thread. From Java 5.0+ one can get such pool from Executors using following method –
public static ExecutorService 
               newFixedThreadPool(int nThreads)
    Creates a thread pool that reuses a fixed number of threads operating off a shared unbounded queue. At any point, at most nThreads threads will be active processing tasks. If additional tasks are submitted when all threads are active, they will wait in the queue until a thread is available. If any thread terminates due to a failure during execution prior to shutdown, a new one will take its place if needed to execute subsequent tasks. The threads in the pool will exist until it is explicitly shutdown.

Example-
Suppose we have 100 properties files in an application. We have one thread that can read properties file and return a map value. We want to optimize the time to read all 10 properties file by using concurrent reading. Here optimize means – we need a perfect balance between CPU Utilization and total time consumed by reading process.

Pseudo code – READER THREAD

Config Reader implements Callable<Map<String, String>
try{
    // Get the file name in the constructor of thread
    // Check if File exists
    // Read the file and retrun the map object
}catch(Exception e){
        //release all the resource
        //return null
}

Main THREAD-
        // Get a fixed thread pool from Executors
 try{
    // Get the list of all properties file in the directory
    // Create a READER THREAD by passing the name of file
    // store the READER thread in the a list
    //release all the thread in one go and get the Map objects
}catch(Exception e){
                //release all the resources
                // print the stack trace
}finally{
        //shutdown the thread pool
}

package com.jovialjava.blog.threads;

import java.io.File;
import java.io.FileInputStream;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

class Reader implements Callable<Properties> {

    private String name = null;

    public Reader(String name) {
        this.name = name;
    }

    public Properties call() {
        try {
            File f = new File(name);
            Properties prop = new Properties();
            if (f.exists() && f.canRead() && f.isFile()) {
                FileInputStream in = new FileInputStream(f);
                prop.load(in);
                return prop;
            } else {
                System.err.println("Please check about this file:[" + f.getAbsolutePath() + "]");
                return null;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
}

public class FixedThreadPoolExample {
    public static String directory = "config";
    private static ExecutorService executorPool = null;

    public static void main(String args) {
        try {
            File dir = new File(directory);
            if (dir.isDirectory()) {
                List<Callable<Properties>> fileList = new ArrayList<Callable<Properties>>();
                String[] files = dir.list();
                /**
                 * Optimization - just 20% of number of files.
                 */
                executorPool = Executors.newFixedThreadPool(files.length / 5);

                for (String file : files) {
                    Callable<Properties> reader = new Reader(dir.getAbsolutePath() + File.separator + file);
                    fileList.add(reader);
                }
                List<Future<Properties>> results = executorPool.invokeAll(fileList);
                /**
                 * Check how many success and how many failure
                 */
                int success = 0, failure = 0;
                for (Future<Properties> result : results) {
                    if (result.get() == null) {
                        failure++;
                    } else {
                        success++;
                    }
                }
                System.out.println("Total number of files [" + fileList.size() + "]");
                System.out.println("Success Count [" + success + "]");
                System.out.println("Failure Count [" + failure + "]");
            } else {
                throw new IllegalArgumentException("There is no such directory name -" + directory);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (executorPool != null) {
                executorPool.shutdown();
            }
        }
    }
}
posted on 2012-08-06 10:43 ゞ沉默是金ゞ 阅读(928) 评论(0)  编辑  收藏 所属分类: Java SE

只有注册用户登录后才能发表评论。
网站导航:
 
Copyright ©2025 ゞ沉默是金ゞ Powered By博客园 模板提供：沪江博客