0

I am trying to implement timeout for a thread which is invoked asynchronously by executor.

Process flow is like below:

Thread-1: Initiates a task to run on thread-2 using below code and returns immediately without waiting for Future object result

Thread-2: Long process and wil update some store some result in cache at end

Now, the requirement is to kill Thread-2 after some timeout value without blocking Thread-1

code snippet: 

    ExecutorService executor = Executors.newFixedThreadPool(1);
    Future<Task> future = executor.submit(new Callable<Task>() {

        public Task call() throws Exception {
            try{

            return new Task();
            }catch (Exception e) {
            //print stack
        }

        }
    });

Any insight/suggestions to implement this?

xingbin
  • 27,410
  • 9
  • 53
  • 103
Ramu Pasupuleti
  • 888
  • 2
  • 15
  • 35
  • There's something you need to concern. 1. How many producer thread as well as consumer thread do you have. 2. In fact, you can not kill thread2 except it is on waiting status. – xingbin Feb 13 '18 at 15:32
  • I don't think this is a good idea. – duffymo Feb 13 '18 at 15:37

3 Answers3

0

See the following answer: https://stackoverflow.com/a/2733370/1299078

But depending on what Thread-2 does, you could let the thread end regularly, i.e. define a timeout on a http-request or a DB statement or if you have a loop, define an exit condition. this way you may end up with a more proper solution and you are able to properly release resources.

claudegex
  • 285
  • 1
  • 4
  • 15
  • if we use solutions in that URL, Thread-1 will be blocked. As per my requirement, it shouldn't – Ramu Pasupuleti Feb 13 '18 at 16:00
  • It is absolutely OK to fork away your call. My point was, that you can specify the timeout in the Tasks you forked away. This way timeout gets hit in Thread-2 and will terminte Thread-2 without blocking Thread-1 and you don't have to actively killing Thread-2. – claudegex Feb 13 '18 at 16:02
0

You can't do it using Java's ExecutorService because it doesn't expose any method to timeout and kill/complete/finish the newly spawned thread.

However, if you must do it then you can do it by directly using Thread class, below is high level approach:

  • From your main thread t1, spawn your worker thread t2 which is supposed to do your long work.
  • In your t1, you will have hold of the t2's ORV, pass it a new thread t3 along with time after which you want t2 to finish.
  • In t3 (you can also do this in t1 if you wish, but since you do not wish to block t1 so you need to have another thread to do this job), once that time has elapsed call t2.interrupt(), this will basically interrupt the t2 thread.
  • Now in t2, you will have to periodically keep on checking whether the thread is interrupted or not (using if (Thread.interrupted()) {) and if it is interrupted then you can do whatever you want to do like - simply return therefore completing/killing/finishing the thread.
hagrawal7777
  • 14,103
  • 5
  • 40
  • 70
0

The basic ExecutorService does not provide a timeout functionality.

You could implement the timeout yourself like described by @hagrawal or you can use guava which has a very nice implementation for what you're asking for here

jeremie
  • 971
  • 9
  • 19