原因最近在完善公司的基础发布平台的时候，使用到了一线程去做一些异步的事情，在开发环境和测试环境验证没有任何问题，但是在程序在生产运行一段时间后，发现没有得到自己想要的结果，为此开始了漫长的排查bug的之路，因为用到了一些线程，但是实际又没有对这些线程足够的监控，所以在排查问题的时候也是历经艰难险阻； 原始代码protected ScheduledExecutorService executorService = Executors.newScheduledThreadPool(2);/** *...
使用NIO对文件进行底层拷贝（按照字节）多线程技术初级应用 不阻塞程序运行package com.lovo.homework01;import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.nio.ByteBuffer; import java.nio.channels.FileChannel;import javax.swing.JButton; impor...
概述之前讲解Thread类中方法的时候，interrupt()、interrupted()、isInterrupted()三个方法没有讲得很清楚，只是提了一下。现在把这三个方法同一放到这里来讲，因为这三个方法都涉及到多线程的一个知识点----中断机制。Java没有提供一种安全、直接的方法来停止某个线程，而是提供了中断机制。中断机制是一种协作机制，也就是说通过中断并不能直接终止另一个线程，而需要被中断的线程自己处理。有个例子举个蛮好，就像父母叮嘱出门在...
一 关键类的实现1 ThreadPoolExecutor类java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类，因此如果要透彻地了解Java中的线程池，必须先了解这个类。下面我们来看一下ThreadPoolExecutor类的具体实现源码。在ThreadPoolExecutor类中提供了四个构造方法： 1publicclass ThreadPoolExecutor extends AbstractExecutorService {2 .....3public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long k...
采用apache 的 commons-net-ftp-ftpclient import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintWriter; import java.io.RandomAccessFile;import org.apache.commons.net.PrintCommandListener; import org.apache.commons.net.ftp.FTP; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons...
1、类说明jdk的concurrent包中的CountDownLatch类是一个线程同步的辅助类，它使得线程可以一直等待在其它线程中执行的操作，直到此操作结束。CountDownLatch在初始化的时候指定一个大小值N，调用CountDownLatch的await方法的线程会陷入等待之中，直到这个CountDownLatch对象的countDown方法被调用N次为止，无论是在一个线程中调用N次，还是在N个线程中被调用一次。只有这个对应的CountDownLatch对象的countDown方法总被调用次数为N...
在DRP项目中，我们使用了ThreadLocal来创建Connection连接，避免了一直以参数的形式将Connection向下传递（传递connection的目的是由于jdbc事务要求确保使用同一个connection连接）。那么ThreadLocal是如果做到的呢？它和同步锁的不同在哪里？ 是什么：对于ThreadLocal看英文单词我们很容易理解为一个线程的本地实现，但是它并不是一个Thread，而是threadlocalvariable(线程局部变量)。也许把它命名为ThreadLocalVar更加合适。线程...
引 如果对什么是线程、什么是进程仍存有疑惑，请先Google之，因为这两个概念不在本文的范围之内。用多线程只有一个目的，那就是更好的利用cpu的资源，因为所有的多线程代码都可以用单线程来实现。说这个话其实只有一半对，因为反应“多角色”的程序代码，最起码每个角色要给他一个线程吧，否则连实际场景都无法模拟，当然也没法说能用单线程来实现：比如最常见的“生产者，消费者模型”。很多人都对其中的一些概念不够明确，如同步...
简介： 1.要了解多线程，首先我们得先了解进程和线程。那么什么是进程？进程就是一个正在运行的程序分配内存让应用程序能够运行的叫做进程。那么什么又是线程呢？线程：在一个程序中，负责代码的执行，就是一个进程中的执行路劲的称为线程。然而，在一个进程中，同时又多个线程在执行不同的任务时，我们就称为多线程。 2.我们为什么要使用多线程呢？因为在一个进程中，有时候执行的任务，不仅仅只执行的是一个任务，有...
package cn.itcast.download;import java.io.File; import java.io.InputStream; import java.io.RandomAccessFile; import java.net.HttpURLConnection; import java.net.URL;publicclass MulThreadDownloader {publicstaticvoid main(String[] args) throws Exception {String path = "http://i1.itc.cn/20140715/340a_ae147e1e_c21f_cc5d_afe0_a08407c77f1b_1.jpg";int threadsize = 3;new MulThreadDownloader().download(path...
好处 ： 线程是稀缺资源，如果被无限制的创建，不仅会消耗系统资源，还会降低系统的稳定性，合理的使用线程池对线程进行统一分配、调优和监控，有以下好处：1、降低资源消耗；2、提高响应速度；3、提高线程的可管理性。Java1.5中引入的Executor框架把任务的提交和执行进行解耦，只需要定义好任务，然后提交给线程池，而不用关心该任务是如何执行、被哪个线程执行，以及什么时候执行。demo1、Executors.newFixedThreadPool(10)初始化...
线程：线程是进程的组成部分，一个进程可以拥有多个线程，而一个线程必须拥有一个父进程。线程可以拥有自己的堆栈，自己的程序计数器和自己的局部变量，但不能拥有系统资源。它与父进程的其他线程共享该进程的所有资源。 线程的特点：线程可以完成一定任务，可以和其它线程共享父进程的共享变量和部分环境，相互协作来完成任务。线程是独立运行的，其不知道进程中是否还有其他线程存在。线程的执行是抢占式的，也就是说，当前执行的...
代码地址：https://github.com/iyuanyb/webserver实现了静态、动态资源获取；Cookie、Session、HTTP 长连接，及 Session 和 HTTP 长连接的定时清除；类似 Spring MVC 的注解式编程，如 @RequestMapping @RequestParam 等，方法中可以根据参数名从前台获取数据，可以传递对象，也支持级联属性，如：// GET /page?pageSize=10&pageNum=1 HTTP/1.1 @RequestMapping("/page") String page(@RequestParam(value="pageSize", defaultValu...
疯狂软件分享 1 wait方法： 该方法属于Object的方法，wait方法的作用是使得当前调用wait方法所在部分(代码块)的线程停止执行，并释放当前获得的调用wait所在的代码块的锁，并在其他线程调用notify或者notifyAll方法时恢复到竞争锁状态(一旦获得锁就恢复执行)。 调用wait方法需要注意几点： 第一点：wait被调用的时候必须在拥有锁(即synchronized修饰的)的代码块中。 第二点：恢复执行后，从wait的下一条语句开始执...
一、JDK5之后的Lock锁的概述和使用package a;import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock;public class SellTicket implements Runnable {//定义票private int tickets = 100;//定义锁对象private Lock lock = new ReentrantLock();@Overridepublic void run() {while(true){try {//加锁lock.lock();if(tickets > 0){try {Thread.sleep(100);} catch (InterruptedException e) {e.p...