Java线程池例子

╰+哭是因爲堅強的太久メ 2022-01-13 09:01 191阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

/\*\*  
 \*   
 \*/  
package iotest.serversocket;  
   
import java.io.BufferedInputStream;  
import java.io.BufferedOutputStream;  
import java.io.File;  
import java.io.FileInputStream;  
import java.io.FileOutputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.OutputStream;  
import java.util.List;  
import java.util.zip.GZIPOutputStream;  
   
/\*\*  
 \* [@author][author] Brandon B. Lin  
 \*   
 \*/  
public class GZipThread extends Thread \{  
   
    private List<File> jobQueue;  
    private static int filesCompressed = 0;  
   
    public GZipThread(List<File> jobQueue) \{  
        this.jobQueue = jobQueue;  
    \}  
   
    private static synchronized void incrementFilesCompressed() \{  
        filesCompressed++;  
    \}  
   
    [@Override][Override]  
    public void run() \{  
        while (filesCompressed != GZipAllFiles  
                .getNumbersOfFilesToBeCompressed()) \{ // if there is any job, even not in jobqueue  
              
            File input = getAJobFromQueue();  
            if(input == null) \{  
                return;  
            \} else \{          
                incrementFilesCompressed();  
                compressedAnFile(input);  
            \}  
        \}  
    \}  
      
    /\*\*  
     \* Get a job from queue if any , null if all job done  
     \*/  
    private File getAJobFromQueue() \{  
          
        File result = null;  
        synchronized (jobQueue) \{  
            while (jobQueue.isEmpty()) \{  
                if (filesCompressed == GZipAllFiles  
                        .getNumbersOfFilesToBeCompressed()) \{  
                    System.out.println(Thread.currentThread() + " ending!");  
                    return result;  
                \}  
                  
                try \{  
                    jobQueue.wait();  
                \} catch (InterruptedException exception) \{  
                    exception.printStackTrace();  
                \}  
            \}  
            result =  jobQueue.remove(jobQueue.size() - 1);  
        \}  
        return result;  
    \}  
   
    /\*\*  
     \* compress an file  
     \*/  
    private void compressedAnFile(File fileToBeCompressed) \{  
        if (!fileToBeCompressed.getName().endsWith(".gz")) \{ // 不压缩已经压缩的文件  
            try \{  
                InputStream in = new BufferedInputStream(new FileInputStream(  
                        fileToBeCompressed));  
                File output = new File(fileToBeCompressed.getParent(),  
                        fileToBeCompressed.getName() + ".gz");  
                if (!output.exists()) \{ // 不重复压缩  
                    OutputStream out = new BufferedOutputStream(  
                            new GZIPOutputStream(new FileOutputStream(output)));  
                    copyIntoOut(in, out);  
                \}  
            \} catch (IOException exception) \{  
                exception.printStackTrace();  
            \}  
        \}  
    \}  
   
    /\*\*  
     \* copy data from in to out  
     \*/  
    private void copyIntoOut(InputStream in, OutputStream out)  
            throws IOException \{  
        int readByte;  
        while ((readByte = in.read()) != -1) \{  
            out.write(readByte);  
        \}  
        out.flush();  
        out.close();  
        in.close();  
    \}  
   
\}

/\*\*  
 \*   
 \*/  
package iotest.serversocket;  
   
import java.io.File;  
import java.util.Vector;  
   
/\*\*  
 \* [@author][author] Brandon B. Lin  
 \*   
 \*/  
public class GZipAllFiles \{  
   
    public final static int THREAD\_COUNT = 4;  
    private static int filesToBeCompressed = -1;  
    private static GZipThread\[\] threads = new GZipThread\[THREAD\_COUNT\];  
    private static Vector<File> jobQueue = new Vector<>();  
   
    public static void main(String\[\] args) \{  
        createThreadPool();  
        String directoryToBeCompressed = "F:\\\\java\\\\UML\\\\";  
        addFilesToJobQueue(directoryToBeCompressed);  
        notifyAllThreadNoMoreJobs();  
    \}  
      
    /\*\*  
     \* create THREAD\_COUNT threads in thread pool  
     \*/  
    private static void createThreadPool() \{  
        for (int i = 0; i < threads.length; i++) \{  
            threads\[i\] = new GZipThread(jobQueue);  
            threads\[i\].start();  
        \}  
    \}  
      
    /\*\*  
     \* if parameter is an file, add the file to jobQueue,  
     \* if parameter is an directory, add first level's uncompressed files to jobqueue  
     \*/  
    private static void addFilesToJobQueue(String directory) \{  
        File file = new File(directory);  
        int totalFiles = 0;  
          
        if (file.exists()) \{  
            if (file.isDirectory()) \{  
                totalFiles += addDirectoryToJobQueue(file);  
            \} else \{  
                addAnFileToJobQueue(file);  
                totalFiles++;  
            \}  
        \}  
          
        filesToBeCompressed = totalFiles; // 必须一次性增加  
    \}  
      
    /\*\*  
     \* 添加目錄的第一級文檔到作業隊列  
     \*/  
    private static int addDirectoryToJobQueue(File directory) \{  
        File\[\] files = directory.listFiles();  
        int numberOfFiles = 0;  
        for (int j = 0; j < files.length; j++) \{  
            if (!files\[j\].isDirectory()) \{  
                addAnFileToJobQueue(files\[j\]);  
                numberOfFiles++;  
            \}  
        \}  
        return numberOfFiles;  
    \}  
      
    /\*\*  
     \* add an file (not directory) to jobqueuqe  
     \*/  
    private static void addAnFileToJobQueue(File fileToAdd) \{  
        synchronized (jobQueue) \{  
            jobQueue.add(0, fileToAdd);  
            jobQueue.notifyAll();  
        \}  
    \}  
      
    /\*\*  
     \* Notify all threads in thread pool that no more job will be added.  
     \*/  
    private static void notifyAllThreadNoMoreJobs() \{  
        for (int i = 0; i < threads.length; i++) \{  
            threads\[i\].interrupt();  
        \}  
    \}  
   
    /\*\*  
     \* How many files need to be compressed  
     \*/   
    public static int getNumbersOfFilesToBeCompressed() \{  
        return filesToBeCompressed;  
    \}  
   
\}

欢迎工作一到五年的Java工程师朋友们加入Java技术交流：659270626  
群内提供免费的Java架构学习资料（里面有高可用、高并发、高性能及分布式、Jvm性能调优、Spring源码，MyBatis，Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多个知识点的架构资料）合理利用自己每一分每一秒的时间来学习提升自己，不要再用"没有时间“来掩饰自己思想上的懒惰！趁年轻，使劲拼，给未来的自己一个交代！

转载于:https://my.oschina.net/u/4094976/blog/3050416

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220113/36c0d88bd7a44ebda78a2d498f107bbe.png
[author]: https://my.oschina.net/arthor
[Override]: https://my.oschina.net/u/1162528