首页 文章
  • 2 votes
     answers
     views

    使用Cassandra的Spark任务

    我是Spark和Cassandra的新手 . 我们在Cassandra上使用Spark来读取数据,因为我们需要使用非主键列来读取数据 . 一个观察结果是,火花作业的任务数量增加了数据增长 . 因此,我们在获取数据时面临很多延迟 . 火花工作任务数量增加的原因是什么? 用Cassandra提高Spark性能应该考虑什么? 请建议我 . 谢谢,Mallikarjun
  • 0 votes
     answers
     views

    WSO2 DSS 3.5.0 - DataService任务类错误

    我目前正在研究WSO2 DSS 3.5.0,试图遵循这个例子:https://itsmeisuru.wordpress.com/2013/11/29/wso2-dss-scheduled-task-example/ 我已经创建了一个实现“DataTask”的简单java类的JAR文件 . 它将此JAR放在存储库DSS_HOME / repository / components / lib中,就像...
  • 0 votes
     answers
     views

    不会从Xamarin.forms上的AbsoluteLayout的Children中删除图像

    我正在使用Xamarin.forms PCL项目制作应用程序 . 我做了我的计时器并且每隔三秒调用一次这个功能 . void CreateBGAndAnimate() { Image bg = new Image() { Source = "_pagebaby_bg.png", Aspect...
  • 1 votes
     answers
     views

    Asp.Net MVC,WebApi和正确的异步方法

    我有一个多层Web应用程序,最近我决定将我的服务层(在本例中为WebApi)转换为异步处理 . 在这方面,我转换了所有的WebApi方法来实现任务,在MVC部分,我实现了一个业务层来调用WebApi . 我的MVC控制器只是使用业务层类来获取视图数据 . 我对.Net 4.5中基于任务的编程有点新意,想知道我的方法是正确还是有缺陷 . 在我的简单测试中,我看到响应时间的性能提高,但我不确定我的所有...
  • 2 votes
     answers
     views

    有没有办法找出谁取消任务?

    我知道这听起来很奇怪,但我正在尝试对我们的API进行简单的性能测试,并且取消了导致我的应用程序错误和响应失败的请求 . 我可以看看谁发起了取消吗? 2018-03-12 14:37:10.656 00:00(BettingAPI)(BettingApi)[错误]执行fetchers时抛出的异常,sessionInfo - “siteId:1,customerId:2231,sessionId:...
  • 2 votes
     answers
     views

    异步等待另一个请求而不阻塞

    我有一个websocket应用程序,它是一个OWIN中间件 . 当请求进入时,会启动websocket处理程序的新实例,然后在循环中等待icoming消息,如下所示: var buffer = new byte[1024*64]; Tuple<ArraySegment<byte>, WebSocketMessageType> received; do { recei...
  • 189 votes
     answers
     views

    UI线程上的任务继续

    是否有一种“标准”方式来指定任务延续应该在创建初始任务的线程上运行? 目前我有下面的代码 - 它正在工作,但跟踪调度程序和创建第二个动作似乎是不必要的开销 . dispatcher = Dispatcher.CurrentDispatcher; Task task = Task.Factory.StartNew(() => { DoLongRunningWork(); }); Ta...
  • 260 votes
     answers
     views

    任务与线程差异[重复]

    这个问题在这里已有答案: What is the difference between task and thread? 7个答案 我是并行编程的新手 . .NET中有两个类: Task 和 Thread . 所以,问题是:这些课程有什么区别?何时使用 Thread 和 Task 时更好?
  • 0 votes
     answers
     views

    使用Task管理线程异常

    我正在我的主线程中创建一个任务来管理我的线程 . 我的目的是从AggregateException中受益,所以我希望我的任务在任务中启动的线程中发生异常时返回该异常,如下面的代码块所示 . public void ReportGeneratorFiveThreadTest() { var logger = new Log4NetLogger(typeof(ReportGeneratorTh...
  • 1 votes
     answers
     views

    Gradle创建多项目Jar

    因此,自从他们成立初期以来,我一直在Gradle和Android Studio中玩游戏 . 然而,我发现自己在墙壁上撞击的次数远远超过了它的次数值得:( . 我花了一天半时间试图解决目前的困境 . 在我工作的地方,我们使用了很多共享的库项目 . 这意味着,与Gradle的原生假设不同,我的项目并非全部嵌套在一个父项目下 . (但这不是我的问题)我已经得到了这个工作 . 在我们的项目完成并准备好之...
  • 1 votes
     answers
     views

    无法理解创建可执行fat-jar的gradle jar任务代码

    我正在学习Gradle但是我不理解创建一个包含所有依赖项的jar的jar任务代码(取自Gradle Cookbook): jar { baseName = jarBaseName manifest { attributes "Main-Class": mainClass } from { configurations.compile.collect { ...
  • 1 votes
     answers
     views

    芹菜任务应排在 Worker 迷路的排队

    我正在使用django-celery 3.2和芹菜3.1.25 . 我添加了以下设置 - CELERY_TASK_ACKS_LATE = True task_reject_on_worker_lost = True 如果我使用芹菜4.x与django-celery 3.2,应用程序会导致以下错误并且无法加载 ImportError:没有名为vine.five的模块 Steps to repr...
  • 0 votes
     answers
     views

    我如何同步django芹菜任务?

    我有两个芹菜任务 @app.task(bind=True) def task1(): @app.task(bind=True) def task2(): 并且每个任务都由不同的api调用,如下所示 @api_view(['POST']) @permission_classes((IsAuthenticated,)) def api1(request): task_1.delay() ...
  • 0 votes
     answers
     views

    Powershell任务计划程序被困运行

    我试图用任务调度程序测试一个简单的PowerShell脚本,状态显示正在运行,但powershell控制台从未出现过 . 我的ps1脚本只包含两个简单的命令: dir 暂停 这是我的设置: General 运行用户是否登录(勾选) 以最高权限运行(检查) Actions 操作:启动程序 程序/脚本:C:\ Windows \ System32 \ WindowsPo...
  • 0 votes
     answers
     views

    Visual Basic异步任务而不是同步任务

    我有一个执行同步任务的函数,我会做同样的但是使用异步任务 . 我应该怎么做 ? 这是代码: 公共类Form1私有任务作为任务 Private Sub Button_Start_Click(sender as Object,e As EventArgs)处理Button_Start.Click Dim freq As Double = TextBox1.Text Dim Amp As Dou...
  • 210 votes
     answers
     views

    rails rake任务是否可以访问ActiveRecord模型?

    我正在尝试创建自定义rake任务,但似乎我无法访问我的模型 . 我认为这是rails任务中隐含的内容 . 我在lib / tasks / test.rake中有以下代码: namespace :test do task :new_task do puts Parent.all.inspect end end 这是我的父模型的样子: class Parent < Active...
  • 237 votes
     answers
     views

    正确使用Task.Run时和async-await时

    我想问你关于正确架构何时使用 Task.Run 的意见 . 我在WPF .NET 4.5应用程序(使用Caliburn Micro框架)中遇到了滞后的UI . 基本上我在做(非常简化的代码片段): public class PageViewModel : IHandle<SomeMessage> { ... public async void Handle(SomeMes...
  • 16 votes
     answers
     views

    为什么我的火花工作有这么多的任务?默认情况下获取200个任务

    我有一个spark作业,它接收来自hdfs的8条记录的文件,做一个简单的聚合并将其保存回hdfs . 当我这样做时,我注意到有数百个任务 . 我也不确定为什么有这么多工作?我觉得工作更像是一个动作发生的时候 . 我可以推测为什么 - 但我的理解是,在这段代码中它应该是一个工作,它应该分解为阶段,而不是多个工作 . 为什么不把它分解成各个阶段,为什么它会闯入工作岗位? 至于200多个任务,由于数据量...
  • -1 votes
     answers
     views

    什么是vxworks系统任务tStkPoll和tStack?

    出于测试目的,我将代码片段放在任务交换机挂钩中,以便收集有关任务cpu使用情况的信息 . 在这样做的过程中,我发现了一些我不熟悉的系统任务 . 谁能告诉我tStack和tStkPoll任务的责任是什么?我正在使用Cert Network Stack运行VxWorks Cert 6.6 . 我在运行vxworks 5.5的应用程序上运行此代码,并且这些系统任务不存在;所以我猜他们与证书网络堆栈有关,...
  • 1 votes
     answers
     views

    当火花在客户端模式下任务数量太大时,容器无法启动

    我在运行一些复杂的sql语句的hive上测试spark-sql . 当我的最大工作数太大时,在我的情况下超过70000,应用程序将停留一段时间,然后抛出以下错误消息: 6/07/06 17:53:20 WARN YarnSchedulerBackend $ YarnSchedulerEndpoint:标记为失败的容器:container_1466092136376_0229_01_000002在...
  • 1 votes
     answers
     views

    如何在ADA中重新初始化任务

    我有一个简单的问题: 我在ADA中同时运行了一些任务 . 他们一起创建了一个模拟代表一个想象国家的选举 . 如果出现某种情况,我想重新启动整个模拟 . 所以我想中止每个任务,然后重新启动它们 . 如何在不重新创建任务的情况下执行此操作?我确信有一个更好的方式,但我似乎无法找到它 . 顺便说一句,任务是在一个数组中 . 提前致谢!! with Ada.Text_IO; use Ada.Text_IO...
  • 0 votes
     answers
     views

    REST api Sharepoint . 如何使用Rest api创建子任务?

    我搜索了有关'如何使用rest api在sharepoint中创建子任务'的信息,但无法找到有关此信息
  • 15 votes
     answers
     views

    任务与流程,有什么区别吗?

    我正在攻读我的CS专业的期末考试,主题是分布式系统和操作系统 . 我需要对术语任务,进程和线程有一个很好的定义 . 到目前为止,我确信一个进程是使用自己的内存,程序计数器,寄存器,堆栈等(进程控制块)来表示运行(或挂起但已启动)的程序 . 进程可以运行共享内存的线程,因此与必须通过IPC进行通信的进程相比,可以通过共享内存进行通信 . 但是任务和流程之间的区别是什么 . 我经常读到它们是可互换的,...
  • 1 votes
     answers
     views

    后台任务优化资源的使用

    我的问题是围绕任务的执行和优化资源 . 我通过轮询数据库来获取一组任务 . 大多数这些任务都执行以下操作: 连接到另一台服务器(SQL,MDX,Webservice等)和查询数据 . (不是I / O密集型) 接收数据并保存到服务器上文件夹中的文件(I / O工作) 目前,我正在接近创建任务元数据队列 . 拾取任务元数据并创建任务(以便它运行单独的线程)并执行 . 我现在已将并发任务...
  • 0 votes
     answers
     views

    通过PHP安排任务

    是否可以在php应用程序中创建和安排任务?我想让我的用户可以选择在他们选择的时候安排和运行脚本,而无需他们进入cron作业或Windows任务调度程序 .
  • 2 votes
     answers
     views

    如何在不运行异步方法的情况下排队异步方法的任务结果?

    如果我有一个类,其中包含稍后要执行的任务队列,并且我有 async Task<T> 方法,如何在不执行它的情况下将该异步方法排入队列? 我想“延迟”这个任务,并确保调用者看到它稍后运行,就像在方法体中等待它一样 . ---调用者不应该知道我已经将任务排入队列中 . 现在,如果我的队列已满,我构造并返回一个未运行的新的 Task<T> ,这将返回我的私有异步方法的 .Res...
  • 0 votes
     answers
     views

    WordPress安排任务更新插件选项

    我正在使用wordpress的插件,我需要使用单个事件调度程序更新数据库选项,但它似乎没有触发 . 我的代码: function task_to_perform() { update_option( "number_of_cubes", 50); wp_unschedule_event('lalala_hook'); } add_action( 'lalala...
  • 3 votes
     answers
     views

    Java 生产环境 者/消费者,检测处理结束

    我正在准备一个应用程序,其中一个 生产环境 者生成数百万个任务,然后由可配置数量的消费者处理 . 从 生产环境 者到消费者的通信(可能)将基于队列 . 从运行 生产环境 者/生成任务的线程,我可以使用什么方法等待所有任务的完成?我宁愿不恢复任何定期轮询,看看我的任务队列是否为空 . 在任何情况下,任务队列为空并不能保证最后的任务已完成 . 这些任务可能运行时间相对较长,因此在消费者线程仍处于愉快处...
  • 2 votes
     answers
     views

    确保主线程等待所有任务完成

    我正在编写一个C#控制台应用程序,并且在所有生成的关闭任务都有机会完成之前,主要线程关闭了 . 一般程序流程如下所示: 该程序将目录的路径作为命令行参数 . 然后,它遍历该目录中与特定扩展名匹配的每个文件,并为每个匹配的文件生成一个新任务,以打开并分析该文件: Directory.GetFiles(directoryPath).ToList<string>().Where(x =&gt...
  • 9 votes
     answers
     views

    async和await是单线程真的吗?

    我创建了以下代码: using System; using System.Threading.Tasks; namespace ConsoleApplication2 { class Program { static void Main() { Console.WriteLine("M Start"); ...

热门问题