在Android开发中,有时候我们需要让一个Activity绑定一个Service,进行两者之间的通信。当Activity绑定成功以后,就可以调用Service中的public(或有对应可见级别)的方法。如果Service想把一些信息反馈给Activity,则需要将Activity的Listener ...
分类:
其他好文 时间:
2017-07-14 19:34:38
阅读次数:
240
//测试的线程 public class Record implements Runnable { public int countDown = 10; private static int taskCount = 0; private final int id = taskCount++; pub ...
分类:
其他好文 时间:
2017-07-12 01:22:41
阅读次数:
151
1 package threadTest; 2 3 import java.util.ArrayList; 4 import java.util.Date; 5 import java.util.concurrent.Callable; 6 import java.util.concurrent.E... ...
分类:
编程语言 时间:
2017-07-11 13:26:40
阅读次数:
204
并发快,一个是快在抢占更多处理器资源上,主要体现在多处理器机器运行并发程序。另外是减少没必要的同步等待,比如等待IO等。 Executor是一个接口只有一个方法execute(Runnable) ExecutorService实现Executor接口并且加入其它方法submit,shutdown等 ...
分类:
其他好文 时间:
2017-07-10 19:13:51
阅读次数:
143
Executor是Spark执行任务的进程,Spark启动Executor过程包括如下步骤: 1)使用Spark-submit提交到集群,Master收到RequesSubmitDriver请求。 2)Master调用scheduler把Driver程序发送到worker端执行。 3)Driver执 ...
分类:
其他好文 时间:
2017-07-10 16:50:32
阅读次数:
203
Spark是最为流行的分布式计算框架,这篇文章简要介绍spark 1.X版本任务调度的基本部件及其原理,包括SparkContext,SparkEnv,Executor,TaskScheduler,DAGScheduler以及其他部件。本文参考自《深入理解Spark》(by耿嘉安)一书。 1 Spa ...
分类:
其他好文 时间:
2017-07-08 12:27:02
阅读次数:
277
1.Application:基于spark的用户程序,包含了一个driver program 和集群中多个 executor 2.Driver Program:运行application的main()函数并自动创建SparkContext。通常SparkContext 代表driver progra ...
分类:
其他好文 时间:
2017-07-07 17:29:23
阅读次数:
210
任务取消,线程中断,通过FutureTask和Executor框架,构建可取消的任务和服务。线程的异常处理,JVM关闭 ...
分类:
编程语言 时间:
2017-07-07 17:26:19
阅读次数:
311
1.单个worker queue创建情况: 2. Consumer 创建监听(executor_thread_pool_size = 64): 2. Publisher 发送情况(rpc_response_timeout = 60): ...
分类:
其他好文 时间:
2017-07-06 20:41:30
阅读次数:
320
It could be a resource problem. Try to increase the number of cores and executor and also to assign more RAM to the application then you should increa ...
分类:
其他好文 时间:
2017-06-29 17:50:25
阅读次数:
4185