本文共 2385 字,大约阅读时间需要 7 分钟。
1)继承Thread类,重写run()方法,在run()方法体中编写要完成的任务。
new Thread() { @Override public void run() { super.run(); // } }.start();
2)实现Runnable接口,实现run()方法 ,Runnable对象作为Thread对象的target创建并启动线程
new Thread(new Runnable() { @Override public void run() { // } }).start();
3)实现Callable接口MyCallable类,实现call()方法,使用FutureTask类来包装Callable对象,使用FutureTask对象作为Thread对象的target创建并启动线程;调用FutureTask对象的get()方法可以获得线程执行结束后的返回值,get()方法是阻塞的,等到线程执行完成才会返回结果。
FutureTaskft = new FutureTask (new Callable () { @Override public Integer call() throws Exception { return null; } }); new Thread(ft).start();
run()方法只是线程的主体方法,和普通方法一样,不会创建新的线程。只有调用start()方法,才会启动一个新的线程,新线程才会调用run()方法,线程才会开始执行。
信号量机制,使用Semaphore实现,Semaphore semaphore = new Semaphore(5, true); 当方法进入时,请求一个信号,如果信号被用完则等待,方法运行完,释放一个信号,释放的信号新的线程就可以使用。
public class SemaphoreDemo { public static void main(String[] args) { int threadCount = 20; final Semaphore semaphore = new Semaphore(5, true); for (int i = 0; i < threadCount; i++) { Thread thread = new Thread() { @Override public void run() { try { /** * 在 semaphore.acquire() 和 semaphore.release()之间的代码,同一时刻只允许指定个数的线程进入 * */ semaphore.acquire(); System.out.println(Thread.currentThread().getName() + ":doSomething start-" + LocalDateTime.now() ); Thread.sleep(2000); // 模拟耗时操作 System.out.println(Thread.currentThread().getName() + ":doSomething end-" + LocalDateTime.now() ); semaphore.release(); } catch (Exception e) { } } }; thread.start(); } }}
根据输出可以看到同一时间只有指定个数的线程执行semaphore.acquire()和semaphore.release()之间的代码。
wait()方法属于Object类,调用该方法时,线程会放弃对象锁,只有该对象调用notify()方法后本线程才进入对象锁定池准备获取对象锁进入运行状态。
sleep()方法属于Thread类,sleep()导致程序暂停执行指定的时间,让出CPU,但它的监控状态依然保存着,当指定时间到了又会回到运行状态,sleep()方法中线程不会释放对象锁。
参考:
转载地址:http://hmfyf.baihongyu.com/