discuss the limit on concurrent execution

iamyess

if your programe execute a high-cost-operation under multi-thread

and want to assign the number that the high-cost-operation  can be invoked at the same time...

actually "Thread.sleep()" can't do this, because that your programe is running under multi-thread environment

so check the following simple code, hope it is helpful

1. 
   
2. 
   
3. public class ConcurrentControler {
   
4.        
   
5.         private int limit;
   
6.         private int size = 0;
   
7.         private Object lock = new Object();
   
8.        
   
9.        
   
10.         public ConcurrentControler(){}
    
11.        
    
12.        
    
13.         public int getLimit() {
    
14.                 return limit;
    
15.         }
    
16. 
    
17. 
    
18. 
    
19.         public void setLimit(int limit) {
    
20.                 this.limit = limit;
    
21.         }
    
22. 
    
23.         public void request() throws InterruptedException
    
24.         {
    
25.                 synchronized(lock)
    
26.                 {
    
27.                         while (size>=limit)
    
28.                                 lock.wait();
    
29.                         ++size;
    
30.                 }
    
31.                
    
32.         }
    
33. 
    
34.         public void finish()
    
35.         {
    
36.                 synchronized(lock)
    
37.                 {
    
38.                         --size;
    
39.                         lock.notifyAll();
    
40.                 }
    
41.         }
    
42.        
    
43.         public static void main(String[] args) {
    
44.                
    
45.                 ConcurrentControler controler = new ConcurrentControler();
    
46.                 controler.setLimit(3);
    
47.                 new Thread( new SimpleTest(controler) ).start();
    
48.                 new Thread( new SimpleTest(controler) ).start();
    
49.                 new Thread( new SimpleTest(controler) ).start();
    
50.                 new Thread( new SimpleTest(controler) ).start();
    
51.                 new Thread( new SimpleTest(controler) ).start();
    
52.                 new Thread( new SimpleTest(controler) ).start();
    
53.                 new Thread( new SimpleTest(controler) ).start();
    
54.                 new Thread( new SimpleTest(controler) ).start();
    
55.                 new Thread( new SimpleTest(controler) ).start();
    
56.                
    
57.         }
    
58.        
    
59.         public static class SimpleTest implements Runnable
    
60.         {
    
61. 
    
62.                 private ConcurrentControler queue;
    
63.                 public SimpleTest(ConcurrentControler obj)
    
64.                 {
    
65.                         this.queue = obj;
    
66.                 }
    
67.                
    
68. 
    
69. 
    
70.                 public void run() {
    
71.                        
    
72.                         try{
    
73.                                 queue.request();
    
74.                         }catch(Exception ignored){ignored.printStackTrace();}
    
75.                        
    
76.                         System.out.println("execute...");
    
77. 
    
78.                         //execute some kind of heavy method here
    
79. 
    
80.                         try{
    
81.                                 //Thread.sleep(3000);
    
82.                         }catch(Exception ignored){ignored.printStackTrace();}
    
83. 
    
84.                         queue.finish();
    
85.                        
    
86.                 }
    
87.                
    
88.         }
    
89. 
    
90. }
    
91. 
    

复制代码

[ 本帖最后由 iamyess 于 2008-11-29 08:19 编辑 ]