标签:
1 import java.util.concurrent.ExecutorService; 2 import java.util.concurrent.Executors; 3 import java.util.concurrent.Semaphore; 4 5 public class ThreadTest { 6 private static int thread_num = 500; 7 private static int client_num = 5000; 8 9 public static void main(String[] args,String no) { 10 ExecutorService exec = Executors.newCachedThreadPool(); 11 12 final Semaphore semp = new Semaphore(thread_num); 13 14 for (int index = 0; index < client_num; index++) { 15 16 final int NO = index; 17 18 Runnable run = new Runnable() { 19 public void run() { 20 try { 21 semp.acquire(); 22 //HttpClientTest.postLogin(); 23 System.out.println("Thread:" + NO); 24 semp.release(); 25 } catch (Exception e) { 26 e.printStackTrace(); 27 } 28 } 29 }; 30 exec.execute(run); 31 } 32 exec.shutdown(); 33 } 34 }
标签:
原文地址:http://www.cnblogs.com/liu-ke/p/4213993.html