實現高併發請求，即同一個程序開闢出多個執行緒請求相同的資源 ，再同時對一個資源進行訪問操作。 

我們都知道 要實現一個多執行緒的併發服務可以有兩種方式，一種是繼承 Theard  類 ,另一種是實現Runnable 介面  在java.lang.Theard 包中，可以看到Theard類也是實現了　Ｒunnable 介面 的實現。

下文中 是通過實現Runnable 介面來完成多執行緒併發。

我這裡是實現一個模擬多使用者投標的一個model （投標多用於 p2p 網站中，借款人在平臺發起借款標，投資人可以對該借款標發起投標。）

本地配置的專案spring mvc 模式， web 伺服器為tomcat伺服器 ，

在web.xml 中配置監聽服務，所以已經啟動單一執行緒，在下例子中採用spring 註解， 在當前執行緒中啟動定時服務Scheduled,

/**

 * 
 */
package com.byzk.p2p.thread;


import java.util.HashMap;
import java.util.List;


import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import com.byzk.p2p.admin.base.controller.BaseController;
import com.byzk.p2p.admin.base.util.MD5;
import com.byzk.p2p.admin.user.dao.UserAccountDao;
import com.byzk.p2p.admin.user.dto.User;
import com.byzk.p2p.admin.user.service.UserService;


/***
 * <p>
 * Title:CurrentTime
 * </p>
 * <p>
 * Description:定時執行
 * </p>
 * <p>
 * Company:xbd
 * </p>
 * 
 * @author:Administrator
 * @date:2016年11月2日下午4:29:07
 */
@Component
public class CurrentTime extends BaseController {


@Autowired
private UserService userService;
@Autowired
private UserAccountDao userAccount;


private static Logger logger = Logger.getLogger(CurrentTime.class);


@Scheduled(cron = "0 59 14 * * ? ")
public void execute() {
// 查詢所有使用者
Integer index =0;
List<User> userList = userService.listAll1(new HashMap<String, Object>());
try {
if (userList != null && userList.size() > 0) {
for (User user : userList) {
TestThread runnable = new TestThread();
if (StringUtils.isNotBlank(user.getFuionAccount()) && "N".equals(user.getFuionAccount())) {
continue;
}
   if(index>=15){
   break;
   }
runnable.setUserId(user.getId());
runnable.setBorrowId(12230);
runnable.setAmount(100.00);
runnable.setThread(runnable);
if(StringUtils.isNotBlank(user.getDealPassword()) && MD5.GetMD5Code("jx123456").equals(user.getDealPassword())){
runnable.setPassword("jx123456");
}
   if(StringUtils.isNotBlank(user.getDealPassword()) &&MD5.GetMD5Code("jx654321").equals(user.getDealPassword())){
runnable.setPassword("jx654321");
   }
new Thread(runnable).start();
logger.info(Thread.currentThread().getName() + "使用者【" + user.getUsername() + "】發起投標請求"); index++;
}
}
} catch (Exception e) {
}
}

        這是一個新的程式入口， 測試兩個執行緒的併發。

/**
* 
* <p>Description:程式入口主函式 </p>
* <p>Company:xbd </p>
* @author:lilei
* @date:2016年11月4日下午2:14:40
*/
public static void main(String []args){
TestThread t = new TestThread();
// 使用者1
t.setUserId(2381);
t.setAmount(200.00);
t.setBorrowId(12230);
t.setPassword("jx123456");
t.setThread(t);
new Thread(t).start();

TestThread t1 = new TestThread();
// 使用者2
t1.setUserId(15167);
t1.setAmount(100.00);
t1.setBorrowId(12230);
t1.setPassword("jx654321");
t1.setThread(t1);
new Thread(t1).start();

}

}

/**
 * 
 */
package com.byzk.p2p.thread;


import org.apache.log4j.Logger;


import com.byzk.p2p.admin.fuiou.config.Config;
import com.byzk.p2p.admin.fuiou.util.WebUtils;
import com.byzk.p2p.admin.user.dto.User;
/*** <p>Title:MtThread </p>
* <p>Description: </p>
* <p>Company:xbd </p>
* @author:Administrator
* @date:2016年11月2日下午4:28:04 */
public class TestThread  implements Runnable{




private Double amount;
private String password;
private Integer borrowId;
private TestThread thread;
    private Integer userId;


/**
* @return the userId
*/
public Integer getUserId() {
return userId;
}


/**
* @param userId the userId to set
*/
public void setUserId(Integer userId) {
this.userId = userId;
}


private static  Logger logger = Logger.getLogger(TestThread.class);
/**
* @return the amount
*/
public Double getAmount() {
return amount;
}


/**
* @param amount the amount to set
*/
public void setAmount(Double amount) {
this.amount = amount;
}


/**
* @return the password
*/
public String getPassword() {
return password;
}


/**
* @param password the password to set
*/
public void setPassword(String password) {
this.password = password;
}


/**
* @return the borrowId
*/
public Integer getBorrowId() {
return borrowId;
}


/**
* @param borrowId the borrowId to set
*/
public void setBorrowId(Integer borrowId) {
this.borrowId = borrowId;
}


/**
* @return the thread
*/
public TestThread getThread() {
return thread;
}


/**
* @param thread the thread to set
*/
public void setThread(TestThread thread) {
this.thread = thread;
}






/**
* 建構函式
*/
public TestThread(){
}

public TestThread(TestThread thread){
this.thread =  thread;
}

@Override
public void run() {
String backStr="";
try {
backStr = WebUtils.sendHttp(Config.server_url+"/front/tender/save1", this.getThread());
logger.info(Thread.currentThread().getName()+"-----------is Tender borrow-----------詳細資訊 ");
} catch (Exception e) {
// TODO Auto-generated catch block
logger.info("錯誤訊息："+e.getMessage());
}
}


}

其中 config 類      WebUtils 類 涉及到 別的同事的 研發     未公開 望海涵！