Author: hoang_to Date: 2010-11-10 07:09:59 -0500 (Wed, 10 Nov 2010) New Revision: 5007 Added: portal/branches/branch-GTNPORTAL-1643/component/portal/src/test/java/org/exoplatform/portal/config/TestConcurrencyDataStorage.java Log: GTNPORTAL-1582: Add JUnit tests illustrating page creation in multi threads Added: portal/branches/branch-GTNPORTAL-1643/component/portal/src/test/java/org/exoplatform/portal/config/TestConcurrencyDataStorage.java =================================================================== --- portal/branches/branch-GTNPORTAL-1643/component/portal/src/test/java/org/exoplatform/portal/config/TestConcurrencyDataStorage.java (rev 0) +++ portal/branches/branch-GTNPORTAL-1643/component/portal/src/test/java/org/exoplatform/portal/config/TestConcurrencyDataStorage.java 2010-11-10 12:09:59 UTC (rev 5007) @@ -0,0 +1,138 @@ +/* + * Copyright (C) 2009 eXo Platform SAS. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.exoplatform.portal.config; + +import java.util.concurrent.CountDownLatch; + +import org.exoplatform.container.PortalContainer; +import org.exoplatform.portal.config.model.Page; +import org.exoplatform.portal.config.model.PortalConfig; +import org.exoplatform.portal.pom.config.POMSessionManager; + +/** + * @author <a href="mailto:hoang281283@gmail.com">Minh Hoang TO</a> + * Nov 10, 2010 + */ + +public class TestConcurrencyDataStorage extends AbstractPortalTest +{ + + private DataStorage storage_; + + private POMSessionManager mgr; + + public TestConcurrencyDataStorage(String name) + { + super(name); + } + + public void setUp() throws Exception + { + super.setUp(); + begin(); + PortalContainer container = PortalContainer.getInstance(); + storage_ = (DataStorage)container.getComponentInstanceOfType(DataStorage.class); + mgr = (POMSessionManager)container.getComponentInstanceOfType(POMSessionManager.class); + + } + + public void testCreatePageConcurrently() throws Exception + { + CountDownLatch startSignal = new CountDownLatch(1); + + for (int i = 0; i < 5; i++) + { + Thread thread = new Thread(new CreatePageTask(mgr, storage_, startSignal, "test" + i, "foo" + i)); + thread.start(); + } + + startSignal.countDown(); + } + + public void testCreatePageSequentially() throws Exception + { + for (int i = 5; i < 10; i++) + { + Thread thread = new Thread(new CreatePageTask(mgr, storage_, null, "test" + i, "foo" + i)); + thread.start(); + thread.join(); + } + } + + protected void tearDown() throws Exception + { + end(); + super.tearDown(); + } + + public class CreatePageTask implements Runnable + { + private DataStorage dataStorage; + + private POMSessionManager sessionManager; + + private String pageName; + + private String pageTitle; + + private CountDownLatch startSignal; + + public CreatePageTask(POMSessionManager _sessionManager, DataStorage _dataStorage, CountDownLatch _startSignal, String _pageName, String _pageTitle) + { + dataStorage = _dataStorage; + pageName = _pageName; + pageTitle = _pageTitle; + sessionManager = _sessionManager; + startSignal = _startSignal; + } + + @Override + public void run() + { + try + { + if(startSignal != null) + startSignal.await(); + + sessionManager.openSession(); + + Page page = new Page(); + page.setOwnerType(PortalConfig.PORTAL_TYPE); + page.setOwnerId("test"); + page.setTitle(pageTitle); + page.setName(pageName); + + dataStorage.create(page); + + Page createdPage = dataStorage.getPage(page.getPageId()); + assertNotNull(createdPage); + assertEquals(pageName, createdPage.getName()); + assertEquals(pageTitle, createdPage.getTitle()); + + System.out.println("Current POMSession: " + sessionManager.getSession().toString()); + } + catch (Exception ex) + { + ex.printStackTrace(); + System.out.println("Could not create the page: " + pageName + " , " + pageTitle); + } + } + } + +}