Go语言视频零基础入门到精通

javalearner

1.单线程实现
    package com.mime;

import java.io.File;

public class TotalFileSizeSequential {
        private long getTotalSizeOfFilesInDir(final File file) {
                if (file.isFile())
                        return file.length();
                final File[] children = file.listFiles();
                long total = 0;
                if (children != null)
                        for (final File child : children)
                                total += getTotalSizeOfFilesInDir(child);
                return total;
        }

        public static void main(final String[] args) {
                final long start = System.nanoTime();
                final long total = new TotalFileSizeSequential()
                                .getTotalSizeOfFilesInDir(new File(args[0]));
                final long end = System.nanoTime();
                System.out.println("Total Size: " + total);
                System.out.println("Time taken: " + (end - start) / 1.0e9);
        }
}[/code]
     2使用Executors.newFixedThreadPool和callable 多线程实现
    3使用Executors.newFixedThreadPool和callable 多线程的另外一种实现
    4.使用CountDownLatch和AtomicLong实现多线程下的并发控制
     5.使用BlockingQueue和AtomicLong的实现
    package com.mime;

import java.io.File;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;

public class ConcurrentTotalFileSizeWQueue {
        private ExecutorService service;
        final private BlockingQueue<Long> fileSizes = new ArrayBlockingQueue<Long>(
                        500);
        final AtomicLong pendingFileVisits = new AtomicLong();

        private void startExploreDir(final File file) {
                pendingFileVisits.incrementAndGet();
                service.execute(new Runnable() {
                        public void run() {
                                exploreDir(file);
                        }
                });
        }

        private void exploreDir(final File file) {
                long fileSize = 0;
                if (file.isFile())
                        fileSize = file.length();
                else {
                        final File[] children = file.listFiles();
                        if (children != null)
                                for (final File child : children) {
                                        if (child.isFile())
                                                fileSize += child.length();
                                        else {
                                                startExploreDir(child);
                                        }
                                }
                }
                try {
                        fileSizes.put(fileSize);
                } catch (Exception ex) {
                        throw new RuntimeException(ex);
                }
                pendingFileVisits.decrementAndGet();
        }

        private long getTotalSizeOfFile(final String fileName)
                        throws InterruptedException {
                service = Executors.newFixedThreadPool(100);
                try {
                        startExploreDir(new File(fileName));
                        long totalSize = 0;
                        while (pendingFileVisits.get() > 0 || fileSizes.size() > 0) {
                                final Long size = fileSizes.poll(10, TimeUnit.SECONDS);
                                totalSize += size;
                        }
                        return totalSize;
                } finally {
                        service.shutdown();
                }
        }

        public static void main(final String[] args) throws InterruptedException {
                final long start = System.nanoTime();
                final long total = new ConcurrentTotalFileSizeWQueue()
                                .getTotalSizeOfFile("/home");
                final long end = System.nanoTime();
                System.out.println("Total Size: " + total);
                System.out.println("Time taken: " + (end - start) / 1.0e9);
        }
}[/code]
     6，使用jdk7的ForkJoin来实现
   

   
     
     
      
      

        
      

        
      
     
   

  


源码下载：http://file.javaxxz.com/2014/10/30/235832234.zip