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

javalearner

这次我们来基于java设计并实现一个简单的任务池。 什么叫任务池？     实际上就是一个任务流水线，可以将各种待完成的任务发布到流水线中。由任务池统计管理并且调度，来保证任务的完成。可能会有这样的疑问：我对每个任务都单独起一个线程，让其独立完成不就可以了么？对于小批量、快速、占用少量资源的任务可能这样没有问题，但是对于大规模、多并发的任务，这样的结果是会造成系统性能极其低下，并且还很可能造成资源需求上的溢出。 如何用有限的资源，调度并完成任务，这就是我们任务池的最终目标。 很直观，直接上任务池中就是有一个队列存储任务对象，对于每个任务它能知道当前任务状态（尚未开始、进行中、已完成）。当一个任务完成的时候，它将该任务清除，并且取出一个其他尚未完成的任务并开启之。  
  
   
   
     
   

     
   
  
    任务池应该具有并发性能，可以限制同时最多有多少个任务并行执行。 好，需求明确了，下面直接看代码吧。该代码实现子任务调用FFMPEG进行视频转码，而任务管理池用于限制并调度任务并发的执行。

1. 
   
2. /**  
   
3. *   
   
4. */  
   
5. package com.nvvideo.upload.logic;   
   
6.   
   
7. import java.util.LinkedList;   
   
8.   
   
9.   
   
10. /**  
    
11. * TransferManager  
    
12. * Title: 视频转码任务管理器
    
13. * Description:
    
14. * Date: 2010-7-14
    
15. * Copyright: Copyright (c) 2010
    
16. * Company: novel-supertv.com
    
17. * @author chenggong  
    
18. * @version 1.0  
    
19. */  
    
20. public class TransferManager {   
    
21.       
    
22.     private int maxThreadNum = 1;   
    
23.     private LinkedList
25.    fileList;   
    
26.     private int workingThreadNum = 0;   
    
27.       
    
28.     public TransferManager(){   
    
29.         this.fileList = new LinkedList
30.   
31.    ();   
    
32.     }   
    
33.       
    
34.     /**  
    
35.      * 设置最大并发数  
    
36.      * @param num  
    
37.      */  
    
38.     public void setMaxThreadNum( int num ){   
    
39.         this.maxThreadNum = num;   
    
40.     }   
    
41.       
    
42.     /**  
    
43.      * 增加文件转码任务  
    
44.      * @param task   
    
45.      */  
    
46.     public synchronized void addFileTask( TransferTaskBase task ){   
    
47.         fileList.addFirst(task);   
    
48.     }   
    
49.       
    
50.     /**  
    
51.      * 启动转码任务  
    
52.      */  
    
53.     public void startTransfer(){   
    
54.         if( workingThreadNum >= maxThreadNum )   
    
55.             return;   
    
56.         else{   
    
57.             transferNext();   
    
58.         }   
    
59.     }   
    
60.       
    
61.     private synchronized TransferTaskBase getNextFile(){   
    
62.         if( fileList.size() == 0 )   
    
63.             return null;   
    
64.         else  
    
65.             return fileList.removeLast();   
    
66.     }   
    
67.       
    
68.     protected synchronized void threadLive(){   
    
69.         workingThreadNum++;   
    
70.     }   
    
71.       
    
72.     protected synchronized void threadFinish(){   
    
73.         workingThreadNum--;   
    
74.     }   
    
75.       
    
76.   
    
77.     /**  
    
78.      * 启动下一个转码任务  
    
79.      */  
    
80.     public void transferNext(){   
    
81.         TransferTaskBase task = this.getNextFile();   
    
82.         if( task == null ){   
    
83.             return;   
    
84.         }   
    
85.         else{   
    
86.             task.start();   
    
87.         }   
    
88.     }   
    
89. }
90.    
91. 
    
92. 转码任务基类
    
93. view plaincopy to clipboardprint?
    
94. package com.nvvideo.upload.logic;   
    
95.   
    
96. import com.nvvideo.logic.VideoLogic;   
    
97. import com.nvvideo.po.Video;   
    
98.   
    
99. /**  
    
100. * TransferTaskBase  
     
101. * Title: 视频转码任务基类
     
102. * Description:
     
103. * Date: 2010-7-14
     
104. * Copyright: Copyright (c) 2010
     
105. * Company: novel-supertv.com
     
106. * @author chenggong  
     
107. * @version 1.0  
     
108. */  
     
109. public abstract class TransferTaskBase extends Thread {   
     
110.     protected TransferManager manager;   
     
111.       
     
112.     /**  
     
113.      * 设置管理器  
     
114.      * @param manager  
     
115.      */  
     
116.     public void setManager( TransferManager manager ){   
     
117.         this.manager = manager;   
     
118.     }   
     
119.       
     
120.     protected Video video;   
     
121.     protected VideoLogic videoLogic;   
     
122.       
     
123.     public void setVideo( Video video ){   
     
124.         this.video = video;   
     
125.     }   
     
126.   
     
127.     public void setVideoLogic(VideoLogic videoLogic) {   
     
128.         this.videoLogic = videoLogic;   
     
129.     }   
     
130.   
     
131.     protected String originFileUri;   
     
132.       
     
133.     /**  
     
134.      * 设置源文件名  
     
135.      * @param filename  
     
136.      */  
     
137.     public void setOriginFile( String filename ){   
     
138.         originFileUri = filename;   
     
139.     }   
     
140.       
     
141.     /* (non-Javadoc)  
     
142.      * 开始执行转码任务  
     
143.      * @see java.lang.Thread#run()  
     
144.      */  
     
145.     final public void run(){   
     
146.         manager.threadLive();   
     
147.         this.execute();   
     
148.         manager.threadFinish();   
     
149.         manager.transferNext();   
     
150.     }   
     
151.       
     
152.     /**  
     
153.      * 执行转码  
     
154.      * 必须以阻塞态执行  
     
155.      */  
     
156.     protected abstract void execute();   
     
157. }  
     
158. 
     
159. 调用示例：
     
160. transferManager 任务池
     
161. task 具体任务
     
162. transferManager.addFileTask(task);
     
163. transferManager.startTransfer();
     
165.   

复制代码

  
  
   
   

     
   

     
   
  

复制代码