【阳哥专栏】周末技术分活动第5期

0_TNT_0 · 0_TNT_0

回帖领题

清浅。。 · 清浅。。

看看看看题

祁祯祥 · 祁祯祥

回帖领题

姿_`态 · 姿_`态

阳哥，我来看题啦啦

王震阳老师 · 王震阳老师

姿_`态发表于 2014-12-15 21:15
阳哥，我来看题啦啦

提交答案的时候记得提交截图。

姿_`态 · 姿_`态

就业指导－王震阳老师发表于 2014-12-15 22:33
提交答案的时候记得提交截图。

嗯呢好的。

姿_`态 · 姿_`态

谢谢阳哥指导

王震阳老师 · 王震阳老师

姿_`态发表于 2014-12-16 11:20
谢谢阳哥指导

写的很好：

/*
需求：
通过查询JDK自带的线程池，学习线程池的使用方法。
并做以下练习：通过从线程池中获取的线程执行一个多线程任务（任务自定义）。
想得满分，至少得写出两种线程池的用法，并附带详细的注释。
查阅api
newFixedThreadPool
public static ExecutorService newFixedThreadPool(int nThreads)创建一个可重用固定线程数的线程池，
以共享的无界队列方式来运行这些线程。在任意点，在大多数 nThreads 线程会处于处理任务的活动状态。
如果在所有线程处于活动状态时提交附加任务，则在有可用线程之前，附加任务将在队列中等待。
如果在关闭前的执行期间由于失败而导致任何线程终止，那么一个新线程将代替它执行后续的任务（如果需要）。
在某个线程被显式地关闭之前，池中的线程将一直存在。
newScheduledThreadPool
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)创建一个线程池，
它可安排在给定延迟后运行命令或者定期地执行。
参数：
corePoolSize - 池中所保存的线程数，即使线程是空闲的也包括在内。
返回：
新创建的安排线程池
思路：
1.定义一个专门用于操作线程池的类
类中定义两个方法，分别是线程池的用法
通过查阅api文档，书写线程池用噶
2.在main方法，中创建对象，调用这两个方法
*/
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
class ThreadPool
{
public static void main(String[] args)
{
ThreadPool tp = new ThreadPool();
tp.fixedThreadPool();
try{Thread.sleep(1000);}catch(Exception e){}
tp.scheduledThreadPool();
}
public void fixedThreadPool(){
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(2);//创建一个可重用固定线程数的线程池，以共享的无界队列方式来运行这些线程。这里设定的线程数是2
for (int i = 0; i < 8; i++) {
final int number = i;
fixedThreadPool.execute(new Runnable() {//执行execute(Runnable command) 在将来某个时间执行给定任务。任务代码如下run方法中
public void run() {
try {
System.out.println("fixedThreadPool..两个一起执行"+number);
Thread.sleep(1000);
} catch (InterruptedException e) {
fixedThreadPool.shutdown();
e.printStackTrace();
}
}
});
}
}
public void scheduledThreadPool(){
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);// 创建一个线程池，它可安排在给定延迟后运行命令或者定期地执行。这里延迟的时间设为1
for (int i = 0; i < 8; i++) {
final int number = i;
scheduler.schedule(new Runnable() {//schedule(Runnable command, long delay, TimeUnit unit) 创建并执行在给定延迟后启用的一次性操作。操作的代码如下run方法中run方法中
public void run() {
try {
System.out.println("scheduler。。等待1s在执行"+number);
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}}, 3, TimeUnit.SECONDS);
}
}
}

复制代码

风祭将o · 风祭将o

线程池，有听过，不知道怎么样，来做下

edidada · edidada

回帖领题

小小志 · 小小志

回帖领题

风祭将o · 风祭将o

今天上网看视频自学了线程池，但只是基本的了解，对于其中同步的方法不是很懂。。另外我不知道为什么当在同一个类中不能执行多个线程池，如果已有一个线程池，再定义一个线程池，就会停止上一个线程池的操作，不明白为什么~

王震阳老师 · 王震阳老师

风祭将o 发表于 2014-12-24 23:11
今天上网看视频自学了线程池，但只是基本的了解，对于其中同步的方法不是很懂。。另外我不知道为什么当在同 ...

很给力：

package gaoxin;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/*
*
* 第五期
*通过查询JDK自带的线程池，学习线程池的使用方法。
*并做以下练习：通过从线程池中获取的线程执行一个多线程任务（任务自定义）。
*想得满分，至少得写出两种线程池的用法，并附带详细的注释。
**/
//自定义一个线程类，继承了Thread
class MyThread extends Thread {
int i = 0;
// 定义其中的run方法，方法是打印某线程在执行
public void run() {
while (i++ < 3)
System.out.println(this.getName() + "正在被执行。。。。。");
}
}
// 定义一个类，主要是为了让线程池执行里面的executeMethod方法。
public class ThreadPool {
//定义一个执行方法，形参接受一个线程池
public static void executeMethod(ExecutorService es) {
//让该线程池添加10个MyThread线程并执行。
for (int x : new int[5]) {
es.execute(new MyThread());
}
}
}
//我分别用三个类来测试三个线程池，是因为线程池之间会相互影响。似乎同一个类中只能同时运行一个线程池？
//单线程的线程池SingleThreadExecutor
//这种线程池里只能同时运行一个线程，如果该线程在运行中因为异常结束了，线程池会重新创建一个线程继续执行。
class SingleThread {
public static void main(String[] args) {
//定义一个单线程的线程池
ExecutorService singleThread = Executors.newSingleThreadExecutor();
//提示这是执行哪个线程池
System.out.println("这是执行singleThreadPool的结果：");
//让它执行ThreadPool类中定义的执行方法。
ThreadPool.executeMethod(singleThread);
//执行完就关闭该线程池
singleThread.shutdown();
//在打印的结果中我们可以看到，它是按顺序执行的，意味着它每次都只能同时运行一个任务。
}
}
//可重用固定数量的线程池FixedThreadPool
//这种线程池里可同时运行指定数量的线程，每完成了一个任务时就再创建一个线程去执行任务，直到线程数量达到线程池可同时运行的最大值。
class FixedThread {
public static void main(String[] args) {
//同上
ExecutorService fixedThread = Executors.newFixedThreadPool(3);
System.out.println("这是执行FixedThreadPool的结果：");
ThreadPool.executeMethod(fixedThread);
fixedThread.shutdown();
//在打印的结果中，我们可以看到，
//它在执行第一个任务后不断地创建新线程去执行余下的任务，直到线程数量达到了可允许的最大值。
//观察结果可发现，它同时执行的线程不超过3个。
}
}
//可缓存的线程池CachedThreadPool
//它也是在完成一个线程任务后再创建一个线程，但不同于fixedThreadPool的是它没有限制数量，
//它里面所能容纳的最大线程数量理论上是依据计算机内存的大小而定的。
//另外，当线程池大小超过需要运行的线程时，线程池就会回收空闲的线程。而任务增加时又将添加新线程来执行任务。
class CachedThread {
public static void main(String[] args) {
//同上
ExecutorService cachedThread = Executors.newCachedThreadPool();
System.out.println("这是执行CachedThreadPool的结果：");
ThreadPool.executeMethod(cachedThread);
cachedThread.shutdown();
//在打印的结果中，我们可以发现可缓存的线程池几乎可以同时运行所有线程。
}
}

复制代码

kongchuiting · kongchuiting

领题看看~~~~~~

佛说 · 佛说

马上就要入学考试了，还差很多技术分，来领题

王震阳老师 · 王震阳老师

佛说发表于 2014-12-29 17:21
马上就要入学考试了，还差很多技术分，来领题

你的技术分已经够了呀

Eagle · Eagle

多线程技术。java掌握的重点部分啊。

执笔画梦 · 执笔画梦

领题试试看

zhouli_2014 · zhouli_2014

领以前的题

随影 · 随影

求领题。

帐号		自动登录	找回密码
密码			加入黑马

【阳哥专栏】周末技术分活动第5期

评分

评分

黑马骑士勋章