// public static void main(String[] args) throws InterruptedException { // https://blog.csdn.net/u011848397/article/details/89074794 // String name = ...
分类:
编程语言 时间:
2019-12-20 20:50:28
阅读次数:
73
public class CompletableFuture2 { public static void main(String[] args) throws InterruptedException { // thenAcceptBoth(); // acceptEither(); // runA ...
分类:
其他好文 时间:
2019-12-12 23:40:50
阅读次数:
96
一、两者共同点: 1)他们都是在多线程的环境下,都可以在程序的调用处阻塞指定的毫秒数,并返回。 2)wait()和sleep()都可以通过interrupt()方法打断线程的暂停状态,从而使线程立刻抛出InterruptedException。如果线程A希望立即结束线程B,则可以对线程B对应的Thr ...
分类:
其他好文 时间:
2019-12-11 21:03:10
阅读次数:
80
基于TCP的socket实现 SocketClient.java public class SocketClient { public static void main(String[] args) throws InterruptedException { try { // 和服务器创建连接 So ...
分类:
编程语言 时间:
2019-12-02 16:38:33
阅读次数:
71
public class CompletableServiceTest { public static void main(String[] args) throws ExecutionException, InterruptedException { // test1(); // test2(); ...
分类:
其他好文 时间:
2019-11-27 01:12:45
阅读次数:
102
FileSystem init() throws URISyntaxException, IOException, InterruptedException { Configuration conf=new Configuration(); conf.set("fs.defaultFS","hdfs ...
分类:
其他好文 时间:
2019-11-25 18:36:13
阅读次数:
79
一、源码分析1、提交job的入口通过job.waitForCompletion(true)完成job的提交以及运行,下面从这个方法入手分析源码。//-----------------job.javapublicbooleanwaitForCompletion(booleanverbose)throwsIOException,InterruptedException,ClassNotFoundExc
分类:
其他好文 时间:
2019-10-24 17:07:02
阅读次数:
95
1 //文件名更改 2 @Test 3 public void testRename() throws IOException, InterruptedException, URISyntaxException { 4 5 //获取文件系统 6 Configuration configuration... ...
分类:
其他好文 时间:
2019-10-08 16:09:32
阅读次数:
225
1 //文件详情查看 2 @Test 3 public void testListFiles() throws IOException, InterruptedException, URISyntaxException { 4 5 //获取文件系统 6 Configuration configura... ...
分类:
其他好文 时间:
2019-10-08 16:05:23
阅读次数:
135
public static void main(String[] args) throws InterruptedException { // Runtime.getRuntime().availableProcessors() 获取可用的cpu数量 int count = Runtime.getR... ...
分类:
编程语言 时间:
2019-10-08 12:35:00
阅读次数:
162