Tag: 任务

找出是否存在芹菜任务: 是否有可能找出具有特定任务ID的任务是否存在？当我试图获得地位时，我会一直等待。 >>> AsyncResult('…').status 'PENDING' 我想知道一个给定的任务ID是否是一个真正的芹菜任务ID，而不是一个随机的string。我想要不同的结果取决于是否有一个有效的任务为一个特定的ID。在过去可能有相同的ID有效的任务，但结果可能已经从后端删除。

等待任务内的asynchronous/等待: 我在我的main()中创build了这个构造 var tasks = new List<Task>(); var t = Task.Factory.StartNew( async () => { Foo.Fim(); await Foo.DoBar(); }); //DoBar not completed t.Wait(); //Foo.Fim() done, Foo.DoBar should be but isn't 但是，当我.Wait t时，它不会等待DoBar()的调用完成。我如何才能真正等待？

运行期间，.NET任务实例能否超出范围？: 如果我有一个方法中的代码块（使用.NET 4和任务并行库）： var task = new Task(() => DoSomethingLongRunning()); task.Start(); 方法返回，这个任务是否会超出范围，被垃圾收集，还是会运行完成？我还没有注意到GCing的任何问题，但是要确保我不会为GC的竞争状态而设置自己。

任务杀手如何工作？: task killer应用程序的有用性是辩论，但我想知道：他们如何实际工作？如何杀死特定的进程？有没有一个API，如果是这样，它实际上做了什么？编辑值得添加：我看到任务杀手应用程序杀死not rooted devices上的进程。所以，我想知道怎么可能杀死你在Android中没有的进程？

在OnlyOnFaulted Continuation中等待任务会导致AggregateException: 我有一些简单的代码作为repro： var taskTest = Task.Factory.StartNew(() => { System.Threading.Thread.Sleep(5000); }).ContinueWith((Task t) => { Console.WriteLine("ERR"); }, TaskContinuationOptions.OnlyOnFaulted); try { Task.WaitAll(taskTest); } catch (AggregateException ex) { foreach (var e in ex.InnerExceptions) Console.WriteLine(e.Message + Environment.NewLine + e.StackTrace); } 但是，我得到一个意外的TaskCanceledException被抛出在try catch块（它在AggregateException InnerExceptions对象）。 “任务被取消了”。为什么我得到这个exception？任务的延续永远不会触发，没有任何exception产生，但我仍然在等待时得到聚合exception…. 我希望有人可以解释这对我有意义:)

在任务中处理exception的正确方法将继续: 请看下面的代码 – static void Main(string[] args) { // Get the task. var task = Task.Factory.StartNew<int>(() => { return div(32, 0); }); // For error handling. task.ContinueWith(t => { Console.WriteLine(t.Exception.Message); }, TaskContinuationOptions.OnlyOnFaulted); // If it succeeded. task.ContinueWith(t => { Console.WriteLine(t.Result); }, TaskContinuationOptions.OnlyOnRanToCompletion); Console.ReadKey(); Console.WriteLine("Hello"); } private static int div(int x, int y) { if (y == […]

芹菜任务，运行更多的任务: 我正在使用celerybeat来启动一系列辅助任务的主要任务。我已经完成了两项任务。有没有办法轻松做到这一点？ Celery是否允许从任务内运行任务？我的例子： @task def compute(users=None): if users is None: users = User.objects.all() tasks = [] for user in users: tasks.append(compute_for_user.subtask((user.id,))) job = TaskSet(tasks) job.apply_async() # raises a IOError: Socket closed @task def compute_for_user(user_id): #do some stuff compute从celerybeat调用，但是当它尝试运行apply_async时会导致IOError。有任何想法吗？

如何使用Python的asyncio模块正确地创build和运行并发任务？: 我正在尝试使用Python 3相对较新的asyncio模块正确理解和实现两个并发运行的Task对象。简而言之，asyncio似乎devise用于处理asynchronous进程和并发Task在事件循环中的执行。它促进使用await （在asynchronous函数中应用）作为一个无callback的方式来等待并使用一个结果，而不会阻塞事件循环。（期货和callback仍是一个可行的select。）它还提供了asyncio.Task()类，这是Future一个专门的子类，用于包装协程。最好通过使用asyncio.ensure_future()方法来调用。 asyncio任务的预期用途是允许独立运行的任务与同一事件循环内的其他任务“同时”运行。我的理解是Tasks连接到事件循环，然后在await语句之间自动继续驱动协程。我喜欢能够使用并发任务而不需要使用某个Executor类的想法，但是我没有find关于实现的详细说明。这就是我目前的做法： import asyncio print('running async test') async def say_boo(): i = 0 while True: await asyncio.sleep(0) print('…boo {0}'.format(i)) i += 1 async def say_baa(): i = 0 while True: await asyncio.sleep(0) print('…baa {0}'.format(i)) i += 1 # OPTION 1: wrap in Task object # […]

我的C＃应用程序返回0xE0434352到Windows任务计划程序，但它不会崩溃: 我已经写了几个C＃应用程序，我已经通过Windows任务计划程序运行。他们正在成功运行（我可以从他们正在写的日志文件中看到），但Windows任务调度程序显示他们返回0xE0434352的最后运行结果。有什么我需要在我的C＃应用程序做，以便它返回一个成功的代码到Windows任务调度？

Android：取消asynchronous任务: 我使用asynchronous任务来上传图像并获得一些结果。在上传图片时，我看到一个进度对话框，用如下方法写入onExpExcute（）方法： protected void onPreExecute() { uploadingDialog = new ProgressDialog(MyActivity.this); uploadingDialog.setMessage("uploading"); uploadingDialog.setCancelable(true); uploadingDialog.show(); } 好的，当我按下后退button时，显然对话框由于setCancelable（true）而消失。但是（显然）asynchronous任务并没有停止。那我该如何解决这个问题？当我按下后退button时，我想取消对话框和asynchronous任务。有任何想法吗？编辑： find解决scheme 。看到我的答案在下面。