jake1036
导航
BlogJava
首页
新随笔
联系
聚合
管理
<
2010年7月
>
日
一
二
三
四
五
六
27
28
29
30
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
1
2
3
4
5
6
7
统计
随笔 - 19
文章 - 0
评论 - 10
引用 - 0
常用链接
我的随笔
我的评论
我的参与
最新评论
留言簿
给我留言
查看公开留言
查看私人留言
随笔档案
2010年11月 (1)
2010年9月 (1)
2010年8月 (1)
2010年7月 (9)
搜索
最新评论
1. re: java UDP 操作
<font size=4>写的不错!</font>
--o
2. re: java socket连接池
是不是可以在建立一个连接池,比如5个连接到服务器的连接,客户端在需要连接的时候,由服务器发给它一个可用的连接
--songxin
3. re: java socket连接池
@yackl
请问下,有没大概或者简单点的解决办法了?
--songxin
4. re: java socket连接池
这个连接池没什么大的作用啊。
服务器端是在接收到客户端的请求之后起一个线程处理的,
你只能说你有5个线程等待处理socket请求。
--songxin
5. re: java socket连接池[未登录]
垃圾
--aaa
阅读排行榜
1. java socket连接池(5303)
2. java socket非阻塞I/O(4487)
3. java日期控件(2423)
4. java UDP 操作(2371)
5. 利用回调函数在线程和主类中传递信息(782)
评论排行榜
1. java socket连接池(9)
2. java UDP 操作(1)
3. java日期控件(0)
4. java被隐藏的指针(0)
5. java socket非阻塞I/O(0)
java 通过实现Runnable来实现多线程
一 利用Runnable接口来实现多线程,并在线程类中添加一个方法来实现获取线程中的信息
下面是线程类
线程对外返回的是 digest 字节数组 。
package
cn.bupt.thread;
import
java.io.
*
;
import
java.security.DigestInputStream;
import
java.security.MessageDigest;
import
java.security.NoSuchAlgorithmException;
public
class
ThreadDemo
implements
Runnable
{
private
File input ;
private
byte
[] digest ;
public
ThreadDemo(File input)
{
this
.input
=
input ;
}
public
byte
[] getDigest()
{
return
digest ;
}
@Override
public
void
run()
{
try
{
FileInputStream in
=
new
FileInputStream(input) ;
MessageDigest sha
=
MessageDigest.getInstance(
"
SHA
"
) ;
DigestInputStream din
=
new
DigestInputStream(in , sha) ;
int
b ;
while
((b
=
din.read())
!=
-
1
) ;
din.close() ;
digest
=
sha.digest() ;
}
catch
(FileNotFoundException e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
catch
(NoSuchAlgorithmException e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
catch
(IOException e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
}
}
2 调用上面的线程类并接收返回的信息
package
cn.bupt.test;
import
java.io.File;
import
cn.bupt.thread.
*
;
public
class
Test
{
/** */
/**
*
@param
args
*/
public
static
void
main(String[] args)
{
//
TODO Auto-generated method stub
ThreadDemo [] td
=
new
ThreadDemo[args.length] ;
for
(
int
i
=
0
; i
<
args.length ; i
++
)
{
/**/
/*
计算摘要
*/
File f
=
new
File(args[i]) ;
td[i]
=
new
ThreadDemo(f) ;
Thread t
=
new
Thread(td[i]) ;
t.start() ;
}
/**/
/*
现在显示结果
*/
for
(
int
i
=
0
; i
<
args.length ; i
++
)
{
StringBuffer result
=
new
StringBuffer(args[i]) ;
result.append(
"
:
"
) ;
byte
[] digest
=
td[i].getDigest() ;
for
(
int
j
=
0
; j
<
digest.length ; j
++
)
{
result.append(digest[j]
+
"
"
) ;
}
System.out.println(
"
result
"
) ;
}
}
}
上面的程序是错误的,原因是当调用getDigest 方法的时候,线程类并没有执行到获得digest的地方,
所以在main函数中得到的代码是NULL pointer 。
3 下面通过 不停地询问检测, 线程返回信息的状态来判断是否已经完成操作 。
代码如下:
package
cn.bupt.test;
import
java.io.File;
import
cn.bupt.thread.
*
;
public
class
Test
{
/** */
/**
*
@param
args
*/
public
static
void
main(String[] args)
{
//
TODO Auto-generated method stub
ThreadDemo [] td
=
new
ThreadDemo[args.length] ;
for
(
int
i
=
0
; i
<
args.length ; i
++
)
{
/**/
/*
计算摘要
*/
File f
=
new
File(args[i]) ;
td[i]
=
new
ThreadDemo(f) ;
Thread t
=
new
Thread(td[i]) ;
t.start() ;
}
/**/
/*
现在显示结果
*/
for
(
int
i
=
0
; i
<
args.length ; i
++
)
{
while
(
true
)
{
byte
[] digest
=
td[i].getDigest() ;
if
(digest
!=
null
)
{
StringBuffer result
=
new
StringBuffer(args[i]) ;
result.append(
"
:
"
) ;
for
(
int
j
=
0
; j
<
digest.length ; j
++
)
{
result.append(digest[j]
+
"
"
) ;
}
System.out.println(
"
result:
"
+
result) ;
break
;
}
}
}
}
}
上面的代码,通过while (true) ,死循环不停地检测当前的返回值,是否为空,不为空则打印。
posted on 2010-07-14 10:27
buptduming
阅读(326)
评论(0)
编辑
收藏
新用户注册
刷新评论列表
只有注册用户
登录
后才能发表评论。
网站导航:
博客园
IT新闻
Chat2DB
C++博客
博问
管理