- 浏览: 489627 次
- 性别:
- 来自: 深圳
-
文章分类
- 全部博客 (234)
- aom学习 (7)
- 2007 (19)
- Java基础 (58)
- spring (7)
- linux (4)
- VMware (3)
- 网络 (3)
- 开发工具类 (14)
- webservices (2)
- 其他 (14)
- database (16)
- hibernate (8)
- jsp_html (14)
- jbpm (5)
- jquery (1)
- 办公软件 (6)
- struts2(webwork) (6)
- web服务器 (2)
- 项目管理 (7)
- 编程规范 (1)
- ps (2)
- JAVA工具类API (4)
- sun_java1.6 (6)
- 金融ISO8583 (1)
- SFTP (1)
- android (1)
- Linux_ftp_命令行下下载文件get与上传文件put的命令应用 (1)
- 公钥+私钥 (1)
- jvm (1)
最新评论
-
fyw2011_huawei：
有没有办法让谷歌也实现该功能？ 因为在谷歌上调试时windo ...
window之createPopup方法 -
技术求：
好，flush 时才是execute
浅谈Hibernate的flush机制 -
xyzc2011：
言简意赅
公钥+私钥 -
smith789：
...
Windows 不能在 本地计算机 启动 OracleDBConsoleorcl -
zengshaotao：
肯定，因为要用到
jquery.js与自己的扩展的.js在导入时有先后顺序
ThreadPoolManager类：负责管理线程池，调用轮询的线程来访问字符串缓冲区的内容，维护缓冲区，当线程池溢出时抛出的Runnable任务被加入到字符缓冲区。
public class ThreadPoolManager
{
private static ThreadPoolManager tpm = new ThreadPoolManager();
// 线程池维护线程的最少数量
private final static int CORE_POOL_SIZE = 4;
// 线程池维护线程的最大数量
private final static int MAX_POOL_SIZE = 10;
// 线程池维护线程所允许的空闲时间
private final static int KEEP_ALIVE_TIME = 0;
// 线程池所使用的缓冲队列大小
private final static int WORK_QUEUE_SIZE = 10;
// 消息缓冲队列
Queue msgQueue = new LinkedList();
// 访问消息缓存的调度线程
final Runnable accessBufferThread = new Runnable()
{
public void run()
{
// 查看是否有待定请求，如果有，则创建一个新的AccessDBThread，并添加到线程池中
if( hasMoreAcquire() )
{
String msg = ( String ) msgQueue.poll();
Runnable task = new AccessDBThread( msg );
threadPool.execute( task );
}
}
}
final RejectedExecutionHandler handler = new RejectedExecutionHandler()
{
public void rejectedExecution( Runnable r, ThreadPoolExecutor executor )
{
System.out.println(((AccessDBThread )r).getMsg()+"消息放入队列中重新等待执行");
msgQueue.offer((( AccessDBThread ) r ).getMsg() );
}
};
// 管理数据库访问的线程池
final ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
CORE_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME, TimeUnit.SECONDS,
new ArrayBlockingQueue( WORK_QUEUE_SIZE ), this.handler );
// 调度线程池
final ScheduledExecutorService scheduler = Executors
.newScheduledThreadPool( 1 );
final ScheduledFuture taskHandler = scheduler.scheduleAtFixedRate(
accessBufferThread, 0, 1, TimeUnit.SECONDS );
public static ThreadPoolManager newInstance()
{
return tpm;
}
private ThreadPoolManager(){}
private boolean hasMoreAcquire()
{
return !msgQueue.isEmpty();
}
public void addLogMsg( String msg )
{
Runnable task = new AccessDBThread( msg );
threadPool.execute( task );
}
}
public class AccessDBThread implements Runnable
{
private String msg;
public String getMsg()
{
return msg;
}
public void setMsg( String msg )
{
this.msg = msg;
}
public AccessDBThread(){
super();
}
public AccessDBThread(String msg){
this.msg = msg;
}
public void run()
{
// 向数据库中添加Msg变量值
System.out.println("Added the message: "+msg+" into the Database");
}
}
public class TestDriver
{
ThreadPoolManager tpm = ThreadPoolManager.newInstance();
public void sendMsg( String msg )
{
tpm.addLogMsg( msg + "记录一条日志 " );
}
public static void main( String[] args )
{
for( int i = 0; i < 100; i++ )
{
new TestDriver().sendMsg( Integer.toString( i ) );
}
}
}
成功地编译Java applet之后生成响应的字节码文件HelloWorld.class的文件。用资源管理器或DIR命令列出目录列表，将会发现目录C:\ghq中多了一个名为HelloWorld.class的文件。
(3)创建HTML文件
在运行创建的HelloWorld.class 之前，还需创建一个HTML文件，appletviewer或浏览器将通过该文件访问创建的Applet。为运行HelloWorld.class, 需要创建包含如下HTML语句的名为HelloWorld.html的文件。
<HTML>
<TITLE>HelloWorld! Applet</TITLE>
<APPLET
CODE="JavaWorld.class"
WIDTH=200
HEIGHT=100>
</APPLET>
</HTML>
本例中，<APPLET>语句指明该Applet字节码类文件名和以像素为单位的窗口的尺寸。虽然这里HTML文件使用的文件名为 HelloWorld.HTML，它对应于HelloWorld.java的名字，但这种对应关系不是必须的，可以用其他的任何名字(比如说 Ghq.HTML)命名该HTML文件。但是使文件名保持一种对应关系可给文件的管理带来方便。
(4)执行 HelloWorld.html
如果用appletviewer运行HelloWorld.html,需输入如下的命令行：
C:\ghq\>appletviewer JavaWorld.html<ENTER>
可以看出，该命令启动了appletviewer并指明了HTML文件，该HTML文件中包含对应于HelloWorld 的<APPLET>语句。
如果用浏览器运行HelloWorld Applet,需在浏览器的地址栏中输入HTML文件URL地址。
至此，一个Applet程序的开发运行整个过程结束了(包括java源文件、编译的class文件、html文件以及用appletviewer或用浏览器运行)。
(二) Applet类
Applet类是所有Applet应用的基类，所有的Java小应用程序都必须继承该类。如下所示。
import java. applet.*;
public class OurApplet extends Applet
{
......
......
}
Applet类的构造函数只有一种，即：public Applet()
Applet实现了很多基本的方法，下面列出了Applet类中常用方法和用途。
public final void setStub(AppletStub stub)
//设置Applet的stub.stub是Java和C之间转换参数并返回值的代码位，它是由系统自动设定的。
public boolean isActive();// 判断一个Applet是否处于活动状态。
public URL getDocumentBase();// 检索表示该Applet运行的文件目录的对象。
public URL getCodeBase();// 获取该Applet 代码的URL地址。
public String getParameter(String name)；// 获取该Applet 由name指定参数的值。
public AppletContext getAppletContext()；// 返回浏览器或小应用程序观察器。 <script src="/ggao/news_js/MyClass_it.js"></script>
public void resize(int width,int height)；// 调整Applet运行的窗口尺寸。
public void resize(Dimension d)；// 调整Applet运行的窗口尺寸。
public void showStatus(String msg)；// 在浏览器的状态条中显示指定的信息。
public Image getImage(URL url)； // 按url指定的地址装入图象。
public Image getImage(URL url,String name)；// 按url指定的地址和文件名加载图像。
public AudioClip getAudioClip(URL url)；// 按url指定的地址获取声音文件。
public AudioClip getAudioClip(URL url, String name)；// 按url指定的地址和文件名获取声音。
public String getAppletInfo()；// 返回Applet应用有关的作者、版本和版权方面的信息；
public String[][] getParameterInfo()；
// 返回描述Applet参数的字符串数组，该数组通常包含三个字符串： 参数名、该参数所需值的类型和该参数的说明。
public void play(URL url)；// 加载并播放一个url指定的音频剪辑。
public void destroy()；//撤消Applet及其所占用的资源。若该Applet是活动的，则先终止该Applet的运行。
(1) Applet运行状态控制基本方法
Applet类中的四种基本方法用来控制其运行状态：init()、start()、stop()、destroy()
init()方法
这个方法主要是为Applet的正常运行做一些初始化工作。当一个Applet被系统调用时，系统首先调用的就是该方法。通常可以在该方法中完成从网页向Applet传递参数，添加用户界面的基本组件等操作。
start()方法
系统在调用完init()方法之后，将自动调用start()方法。而且，每当用户离开包含该Applet的主页后又再返回时，系统又会再执行一遍start()方法。这就意味着start()方法可以被多次执行，而不像init()方法。因此，可把只希望执行一遍的代码放在init()方法中。可以在start()方法中开始一个线程，如继续一个动画、声音等。
stop()方法
这个方法在用户离开Applet所在页面时执行，因此，它也是可以被多次执行的。它使你可以在用户并不注意Applet的时候，停止一些耗用系统资源的工作以免影响系统的运行速度，且并不需要人为地去调用该方法。如果Applet中不包含动画、声音等程序，通常也不必实现该方法。
destroy()方法
与对象的finalize()方法不同，Java在浏览器关闭的时候才调用该方法。Applet是嵌在HTML文件中的，所以 destroty()方法不关心何时Applet被关闭，它在浏览器关闭的时候自动执行。在destroy()方法中一般可以要求收回占用的非内存独立资源。(如果在Applet仍在运行时浏览器被关闭，系统将先执行stop()方法，再执行destroy()方法。
(2) Applet应用的有关参数说明
利用Applet来接收从HTML中传递过来的参数,下面对这些参数作一简单说明：
* CODE标志
CODE标志指定Applet的类名；WIDTH和HEIGHT标志指定Applet窗口的像素尺寸。在APPLET语句里还可使用其他一些标志。
* CODEBASE 标志
CODEBASE标志指定Applet的URL地址。Applet的通用资源定位地址URL，它可以是绝对地址 ，如www.sun.com。也可以是相对于当前HTML所在目录的相对地址，如/AppletPath/Name。如果HTML文件不指定CODEBASE 标志，浏览器将使用和HTML文件相同的URL。
* ALT 标志
虽然Java在WWW上很受欢迎，但并非所有浏览器都对其提供支持。如果某浏览器无法运行Java Applet，那么它在遇到APPLET语句时将显示ALT标志指定的文本信息。
* ALIGN 标志
ALIGN标志可用来控制把Applet窗口显示在HTML文档窗口的什么位置。与HTML<LMG>语句一样，ALIGN标志指定的值可以是TOP、MIDDLE或BOTTOM。
* VSPACE与HSPACE 标志
VSPACE和HSPACE标志指定浏览器显示在Applet窗口周围的水平和竖直空白条的尺寸，单位为像素。如下例使用该标志在Applet窗口之上和之下各留出50像素的空白，在其左和其右各留出25像素的空白：
* NAME 标志
NAME标志把指定的名字赋予Applet的当前实例。当浏览器同时运行两个或多个Applet时，各Applet可通过名字相互引用或交换信息。如果忽略NAME标志，Applet的名字将对应于其类名。
* PARAM 标志
通用性是程序设计所追求的目标之一。使用户或者程序员能很方便地使用同一个Applet完成不同的任务是通用性的具体表现。从HTML文件获取信息是提高Applet通用性的一条有效途径。
假设编制了一个把某公司的名字在屏幕上卷动的Applet。为了使该Applet更加通用，则可以使该Applet从HTML文件获取需要卷动的文本信息。这样，若想显示另一个公司的名字，用不着修改Java Applet本身，只需修改HTML文件即可。
PARAM 标志可用来在HTML文件里指定参数，格式如下所示：
发表评论
-
多线程环境下使用log4j输出各线程的标识
2012-08-15 16:43 1848多线程环境下使用log4j输出各线程的标识 -
证书导入导出
2011-01-16 11:30 1389导入导出命令示例:证书导入:keytool -import - ... -
BigDecimal使用
2010-06-30 12:02 1435public static void main(Str ... -
org.apache.commons.collections.CollectionUtils.filter
2010-06-17 16:11 1689org.apache.commons.coll ... -
Eclipse is running in a JRE, but a JDK is required
2010-05-22 03:47 1234Eclipse is running in a JRE, b ... -
基于StringTemplate的视图
2010-04-21 15:51 1289基于StringTemplate的视图 一 String ... -
JAVA中数组
2010-04-18 23:53 13631、数组不是集合，它只能保存同种类型的多个原始类型或者对象的引 ... -
Java中String类的方法及说明
2010-04-18 23:26 843http://blog.sina.com.cn/s/blog_ ... -
math.ceil round floor
2010-04-18 23:15 1155Math.ceil(x):比x大（或X相等）的最小 doub ... -
5.0新特性：
2010-04-09 16:58 10655.0新特性：前提：1. JVM没有变, 编译器改变 ... -
什么是线程安全？
2010-04-07 03:25 1864什么是线程安全？ 如果你的代码所在的进程中有多个线程在同时 ... -
elipse工作空间中的.metadata
2010-03-26 16:44 1214有时在用eclipse开发时，可能会使编辑器出现异常，这 ... -
BEA WebLogic 9.2平台加速部署Web服务应用
2010-02-23 09:03 2173作为业界知名的Java企业版（JEE）应用基础架构平台，BEA ... -
读内存还是存文件然后读文件
2010-01-28 17:15 1097读内存还是存文件然后读文件，一般优先于读内存为好。 -
spring配置文件名称的最好按java规范进行编写
2010-01-19 09:33 1429spring配置文件名称的最好按java规范进行编写 ... -
Eclipse中安装svn插件Subversive
2010-01-08 11:25 2890最简单的方法是通过Eclipse的插件自动下载和更新功能。 ... -
接口，抽象类
2009-12-02 17:09 1115接口定义了其实现应提供的行为特征 比如 Java code ... -
java基础_容易出错的知识点！
2009-11-30 00:23 1077------------------------------- ... -
java基础_传值与传址方法调用
2009-11-25 02:15 3010public class PassTest { publi ... -
java io
2009-11-18 16:19 1140package com.jeecms.core.action; ...
相关推荐
本篇文章将深入探讨如何使用`java.util.concurrent` 实现线程池队列，以及其中的关键概念和技术。 线程池是一种线程使用模式，通过预先创建并维护一定数量的工作线程来避免频繁创建和销毁线程的开销。在Java中，`...
1. java.util.concurrent - Java 并发工具包 2. 阻塞队列 BlockingQueue 3. 数组阻塞队列 ArrayBlockingQueue 4. 延迟队列 DelayQueue 5. 链阻塞队列 LinkedBlockingQueue 6. 具有优先级的阻塞队列 ...
"java.util.concurrent包中的线程池和消息队列" java.util.concurrent包中的线程池和消息队列是一种高效的多线程编程技术，主要用于解决处理器单元内多个线程执行的问题。线程池技术可以显著减少处理器单元的闲置...
Java.util.concurrent的引入是为了解决传统并发原语如wait()、notify()、synchronized和volatile的使用难度大、容易出错以及性能问题。 在并发编程中，我们经常会遇到需要管理多个线程执行任务的情况。传统的做法是...
"JDK1.5中的线程池(java.util.concurrent.ThreadPoolExecutor)使用" JDK1.5中的线程池(java.util.concurrent.ThreadPoolExecutor)使用是Java多线程编程中的一种重要概念。随着多线程编程的普及，线程池的使用变得...
java.util.concurrent - Java 并发工具包 2. 阻塞队列 BlockingQueue 3. 数组阻塞队列 ArrayBlockingQueue 4. 延迟队列 DelayQueue 5. 链阻塞队列 LinkedBlockingQueue 6. 具有优先级的阻塞队列 ...
### Java并发工具包 `java.util.concurrent` 知识点详解 #### 一、引言 随着多核处理器的普及和应用程序复杂度的增加，多线程编程成为了现代软件开发不可或缺的一部分。为了简化并发编程的复杂性，Java 5 引入了 `...
标题中的“Java实现的线程池、消息队列功能”是指在Java编程中，如何利用编程技术实现线程池和消息队列这两种重要的并发处理机制。线程池和消息队列是解决多线程环境下资源管理和任务调度的有效手段，它们在高并发、...
本资源包含两个 pdf 文档，一本根据 Jakob Jenkov 最新博客 (http://tutorials.jenkov.com/java-util-concurrent/index.html) 整理的 java_util_concurrent_user_guide_en.pdf，一个中文翻译的 java_util_concurrent...
Java并发工具包（java.util.concurrent）是Java平台上用于高效、安全地处理多线程编程的重要组件。这个包包含了丰富的并发工具类，旨在帮助开发者构建高度并发的程序，提高程序的性能和可伸缩性。本资源是该工具包的...
Java.util.concurrent（JUC）是Java平台中的一个核心包，专门用于处理多线程并发问题。这个包包含了大量的工具类和接口，极大地简化了并发编程的复杂性，提高了程序的性能和可伸缩性。本测试源文件主要是针对JUC并发...
此外，`java.util.concurrent` 包的实现充分利用了 JVM 的并发优化，如 CAS（Compare And Swap）操作，以实现高效无锁的数据结构。 总之，`java.util.concurrent` 提供的工具使得并发编程变得更加容易和高效，是 ...
- **线程池管理**：Atlassian Util Concurrent库提供了一种定制化的线程池实现，允许开发者根据具体需求调整线程数量、任务队列策略等，从而有效地管理和控制并发执行的任务。 - **锁和同步机制**：库中包含了各种...
在Java编程领域，`java.util.concurrent`包是并发编程的核心工具包，提供了高效、线程安全的类和接口，使得开发者能够更容易地处理多线程环境。本篇将深入探讨这个包中一些鲜为人知的知识点，以帮助你提升并发编程的...
在Java中，可以使用`java.util.Deque`接口的实现，例如`java.util.concurrent.LinkedBlockingDeque`，它支持双端插入和删除，可以作为线程池的工作队列。 - 在创建`ThreadPoolExecutor`时，可以通过传递`...
Java的并发库（java.util.concurrent）提供了丰富的线程池实现，包括`ThreadPoolExecutor`，它是基于工作窃取算法的高效线程池。本文主要分析的是基于`concurrent`包的一个特定线程池实现，探讨其实现原理和源码。 ...
1. **线程池**: `java.util.concurrent.ExecutorService` 是线程池的基础接口，它允许我们管理一组可重用的工作线程，以提高效率和资源利用率。`ThreadPoolExecutor` 是最常用的实现，可以自定义核心线程数、最大...
- `java.util.concurrent.ThreadPoolExecutor`：普通线程池的核心实现，可配置核心线程数、最大线程数、线程空闲超时时间等参数。 - `java.util.concurrent.ScheduledThreadPoolExecutor`：调度线程池的核心实现，...