java多线程编程，使用sqlserver的存储过程，存到txt文件时的并发问题

0 0

java多线程编程，使用sqlserver的存储过程，存到txt文件时的并发问题10

最近自学的时候遇到了这么一个问题……
首先，任务要求是这样的：
1.在数据库中新建一个用户状态表。里面包含2个字段。user_status（userid bigint,status int）
   userid为自增。
   status默认为0;
   插入1000条记录。

2.写一个存储过程，从user_status表中获取一条status=0的userid字段的值，取出userid时，需要同时把这条记录对应的status从0修改为1.

3.开启2个线程，在线程中循环调用第2步中的存储过程，直到user_status表中记录全部取完(即status全部为1)。要求：在2个线程中取出的userid不能重复。并把取出的userid，打印到某个文件中，一行一个userid

我的存储过程：

ALTER procedure [dbo].[sp_getuserid]
as
declare @userid int
declare @count int
set @count=1
Begin TransAction
select top 1 @userid=userid from user_status where status=0
update user_status set status=1 where status=0 and userid =@userid
set @count = @@ROWCOUNT
If @count=0
begin
rollback TransAction
return 0
end
Else
Begin
select userid from user_status where userid=@userid
Commit TransAction
End

java的程序代码：

public class Status implements Runnable {
	
	private int num;

	@Override
	public void run() {
		Boolean flag = true;
		while(flag)
		{
			this.writeFile(this.getUserid());
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}

	}

	@SuppressWarnings("unchecked")
	public  List<UserBean> getUserid() {
		// 创建数据库连接
		Connection conn = ConnectDb.Connect();

		QueryRunner qRunner = new QueryRunner();
		List<UserBean> list = new ArrayList<UserBean>();
		try {
			list = qRunner.query(conn, "exec sp_getuserid",
					new BeanListHandler(UserBean.class));
		} catch (Exception e) {
			e.printStackTrace();
		}
		DbUtils.closeQuietly(conn);
		return list;

	}

	public  Boolean writeFile(List<UserBean> list) {
		File file = new File("d:/test.txt");
		if (!file.exists())
			try {
				file.createNewFile();
			} catch (IOException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
		if (list==null||list.size()==0)
			return false;
		else {
			try {
				FileOutputStream out = new FileOutputStream(file, true);
				for (int i = 0; i < list.size(); i++) {
					System.out.println("userId:"+list.get(i).getUserid()+"");
					StringBuffer sb = new StringBuffer();
					SimpleDateFormat df = new SimpleDateFormat(
							"yyyy-MM-dd HH:mm:ss:SSS");
					sb.append(df.format(new Date()) + " \t"
							+ list.get(i).getUserid()+ " \t"+this.getNum());
					sb.append(System.getProperty("line.separator"));
					out.write(sb.toString().getBytes("utf-8"));
				}
				out.close();
				return true;
			} catch (Exception e) {
				e.printStackTrace();
				return true;
			}
		}
	}

	public static void main(String[] args) {
			for(int j=0;j<50;j++){
				System.out.println("status["+j+"]"+" start!");
				new Thread(new Status(j)).start();
			}
	}

	public int getNum() {
		return num;
	}

	public void setNum(int num) {
		this.num = num;
	}

	public Status(int num)
	{
		this.num=num;
	}
}

如何解决并发问题啊，我在隔壁也问过这个问题，但是要求是不能增加字段啊……也许是我写的方法太烂了……

现在结果是：在txt中缺少几条数据，但在数据库中已经更新了……也就是说，某些条目虽然在数据库中更新了，但并没有写入到txt中。

Java 多线程存储过程

2014年5月15日 17:56

u010774511
20
0 0 2

2个答案按时间排序按投票排序

0 0

这纯粹是练习呀

一般思路是
1.分页获取数据
2.处理数据写入文件
3.统一更新状态

根据楼主的要求，给出如下思路供楼主参考
public class FixedScheduleTest {

public static ScheduledThreadPoolExecutor executor = null;
public static void main(String[] args) {
executor = new ScheduledThreadPoolExecutor(1);
executor.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
//TODO 1.执行存储过程
//TODO 2.判断是否取完终端线程中断程序
//TODO 3.写入文件
/**
* 中断代码
* executor.shutdown();return ;
*/

}
}, 0, 10, TimeUnit.SECONDS);
}

}